spring-rabbitmq

0熱

1答えて

RabbitMQ - ConfirmCallbackクラスでサービスを注入しようとしていません

ConfirmCallbackインターフェイスを実装している個別のコールバッククラスを作成し、confirm（）をオーバーライドしました。相関データとackは正常に動作しています。しかし、私は@Autowiredを使って、rabbitMQから成功した後にいくつかの他の活動をするサービスを注入しました。しかし、そのサービス参照はまったく注入されません。私は他のクラスで同じサービスを注入しましたが、そ

1熱

1答えて

春のRabbitMQ匿名キュー

春rabbitMQ.Iに新しいですが、正しい次question..Pleaseがあります私は、すなわちアプリケーションの3つのインスタンスを持っています。インスタンス1インスタンス2 インスタンス3 注：インスタンスの数が固定されていないこれらのインスタンスはnumber.Allこれらのインスタンスに固定する必要はないが、同じexchange..Asに耳を傾け、私の要件は、同じメッセージがある

0熱

1答えて

OnMessageを呼び出す前にdefaultメソッドを追加するAmppのMessageListener

実装クラスのonMessage機能を呼び出す前に、Spring AmqpのMessageヘッダから値を選ぶ必要があるいくつかのデフォルト機能を追加する必要があります。例えば、実施例以上のことから class TestListener implements MessageListerner { public void onMessage(Message message){ // some l

0熱

1答えて

カスタムorg.springframework.amqp.support.converter.MessageConverterをRabbitListenerアノテーションで使用する方法は？

私はSpring 4.2とspring-amqp 1.5.5を使用しています。私は自分でorg.springframework.amqp.support.converter.MessageConverterを実装しました。このメッセージコンバータは、メッセージ本体に含まれるプロパティを調べることによって、org.springframework.amqp.core.MessageとJavaオブジェク

0熱

1答えて

メタ注釈を作成して注釈を再利用する

メタ注釈を作成してどこにでも再利用できるかどうかは不思議です。たとえば、次のような注釈があります。 @QueueBinding(value = @Queue, exchange = @Exchange(value = "MY_FANOUT_EXCHANGE", type = ExchangeTypes.FANOUT)) 複数の場所で使用する必要があります。 @MyFanoutExchangeB

0熱

1答えて

実行時にリスナーコンテナからリスナーを追加/削除する方法

実行時にリスナーコンテナからいくつかのリスナーを追加/削除する方法を知りたい。私は以下のようにリスナーコンテナを構成していますので、実行時にXMLから：「リスナーウサギ」とアプリケーションコンテキストを更新 <rabbit:listener-container connection-factory="connectionFactory"> <rabbit:listener ref="L

0熱

1答えて

SimpleMessageListenerContainerが

特定のイベントが到着したことをストーピング後に回復されていない、私はcontainer.stop();を使用して、私のrabbitmq listnerを停止し、必要に応じてジョブが実行された後、私はcontainer.start()でそれを再起動しますが、新しいイベントが到着したとき、私はエラーを以下の取得： Exception in thread "SimpleAsyncTaskExecutor