2017-10-27 8 views
0

私はRabbitMQの簡単なテストをしようとしています。私はErlangとRabbitMQをインストールしています。 私の受信機:それは「channel.queueDeclare」ライン上のキューを宣言立ち往生のでRabbitMQキューの宣言は決して終わりません

private final static String QUEUE_NAME = "hello"; 

public static void main(String[] argv) throws Exception { 
    ConnectionFactory factory = new ConnectionFactory(); 
    factory.setHost("localhost"); 
    Connection connection = factory.newConnection(); 
    Channel channel = connection.createChannel(); 

    channel.queueDeclare(QUEUE_NAME, false, false, false, null); 
    System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); 

    Consumer consumer = new DefaultConsumer(channel) { 
    @Override 
     public void handleDelivery(String consumerTag, Envelope envelope, 
       BasicProperties properties, byte[] body) throws IOException 
     { 
      // TODO Auto-generated method stub 
      String message = new String(body, "UTF-8"); 
      System.out.println(" [x] Received '" + message + "'"); 
     } 
    }; 
    channel.basicConsume(QUEUE_NAME, true, consumer); 
} 

それは、最初にSYSOUTを出力することはありません。 ウサギのログにはAMQP接続を受け入れていると表示され、ユーザーゲストは認証され、仮想ホストへのアクセスが許可されます。

ご協力いただければ幸いです。

答えて

0

私は何の問題もなく、あなたのコードを貼り付け/コピー...

[*] Waiting for messages. To exit press CTRL+C 
[x] Received 'foo' 

私はあなたが管理プラグインを有効にし、管理UIを探る示唆しています。

タグを追加したのはなぜですか?この質問はSpringとは関係がなく、ネイティブクライアントを直接使用しているためですか?

+0

ありがとうございました。タグを修正しました。 ここで、管理プラグインを有効にしてadmin UIを探検するにはどうすればよいですか? – Camilo

+0

https://www.rabbitmq.com/management.html –

関連する問題