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接続を受け入れていると表示され、ユーザーゲストは認証され、仮想ホストへのアクセスが許可されます。
ご協力いただければ幸いです。
ありがとうございました。タグを修正しました。 ここで、管理プラグインを有効にしてadmin UIを探検するにはどうすればよいですか? – Camilo
https://www.rabbitmq.com/management.html –