キューに存在するメッセージの分析RabbitMQ

Question

RabbitMQデフォルト交換を使用してキューにメッセージを送信するJavaクライアントがいくつかあります。

私はキュー内のメッセージを分析できます（明らかに消費されていない場合）。メッセージの送信者を特定し、そのキューにメッセージを送信します。私が知りたいのですがどのようなので、RabbitMQの持つ新しいです

は次のとおりです。

• それがRabbitMQのヘッダとしてクライアントIDを追加することは可能ですか？

• ワークロードの多いクライアント用の特別なキューを作成するにはどうすればよいですか？

• キューに存在するメッセージを分析することはできますか？

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

Answer 1

クライアントIDをRabbitMQのヘッダーとして追加することはできますか？

あなたは多くのワークロードを持つクライアントのための特別なキューを作成する方法BasicProperties

Map<String, Object> headers = new HashMap<String, Object>(); 
headers.put("myclientid", 22222); 

channel.basicPublish(exchangeName, routingKey, 
      new AMQP.BasicProperties.Builder() 
       .headers(headers) 
       .build()), 
       messageBodyBytes); 

にヘッダフィールドを使用することができますか？

ワークロードが高い場合に備えて、特別なキューはなく、同じキューにコンシューマを追加できます。 https://www.rabbitmq.com/tutorials/tutorial-two-java.html

キューに存在するメッセージを分析することは可能ですか？

あなたはこの方法であなたはキュー