spring-rabbit

0熱

1答えて

Spring AMQPを使用している場合、RabbitMQチャンネルでbasicAckのIOExceptionを正しく処理する方法は？春AMQPを使用して、このようなメソッドを宣言した

： @RabbitListener(..) public void myMethod(@Header(AmqpHeaders.CHANNEL) Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) Long tag, ...) やマニュアルを使用するにはどのように1が正常にACKをやったときにスローされる可能性がありIOExceptionに対

0熱

1答えて

使用春の雲春のサービスコネクタおよびパブリッシャーの設定機能

を開始私はスプリンガーパクラウドの設定でのRabbitMQを接続します @Bean public ConnectionFactory rabbitConnectionFactory() { Map<String, Object> properties = new HashMap<String, Object>(); properties.put("publisherConfi

1熱

1答えて

Spring RabbitListenerエイリアスを作成することはできますか？

私は、異なるモジュールを通して私のコード内の複数の場所に貼り付けたコピーのリスナーを@RabbitListener(id="example", queues={"a", "b"})持っています。私は、次のようなエイリアスを作成したい： @Target({ ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE }) @R

0熱

1答えて

キューがダウンすると、RabbitTemplate.executeがハングアップする

RabbitMQチャネルの状態をアサートするためにサーバープロパティを取得しようとしています。ここに私のコードは次のとおりです。私は意図的にウサギのMQを停止してから、このメソッドを実行すると rabbitTemplate.execute(new ChannelCallback<String>() { @Override public String doInRabb

1熱

1答えて

Spring Cloud Stream Rabbit MQに自動的に再接続

RabbitMQサーバーに接続するSpring Cloud Streamアプリケーションがあります。 Rabbit MQでrabbitmq-auth-backend-uaaプラグインを使用していますが、これは問題ではありません。このプラグインは、Rabbit MQとの接続が作成されたときにユーザー名として送信されるoAuth2.0 JWTトークンをチェックします。そうするために、私は私のSpr

1熱

2答えて

Spring RabbitTemplate - 送信時に自動的にキューを作成する方法

私はRabbitMQとSpringのRabbitTemplateを併用しています。テンプレートsendメソッドを使用してキューにメッセージを送信するとき、キューが自動的に作成/宣言されるようにします。私たちのビジネスロジックによれば、実行時にキュー名が生成され、それらを事前に宣言することはできないので、非常に重要です。以前はJmsTemplateを使用していましたが、送信または受信の呼び出し

1熱

1答えて

bean 'org.springframework.amqp.rabbit.config.internalRabbitListenerEndpointRegistry'を開始できませんでした。

私はウサギの送信者と受信者を持つ簡単なスプリングブートアプリケーションを持っています。私は、受信者が同じメッセージを受信したかどうかを確認するために、受信者テストを書いて、Junitクラスルール（RabbitContainerRule）としてrabbitmq dockerインスタンスを実行してから、rabbitTemplateを使用してメッセージを送信します。しかし、私は次の例外取得しています：私

2熱

1答えて

メッセージが正常に確認されたときを確実に知る方法はありますか？

私はSpring AMQPを使用するSpringブートアプリケーションを持っています。 AMQPの設定は次のようになります @Configuration public class AmqpConfig { @Bean DirectExchange directExchange() { return new DirectExchange("amq.direct"); }

0熱

1答えて

Ribbit MQ ClusterのMaster Queue Nodeへの接続をSpring AMQPが常に保証する方法

3ノードRabbit MQのセットアップがあります。実行時にすべてのキューが作成されています。私はその後、キューを反映していない特定のキューは考えNode1で作成され、私はそれを確実にする方法として、その後春AMQPクライアントを使用する場合は、ノード2とノード3今に存在しない場合ノード1で提供されていますQUEUE1は、それは常に他の方法は、任意のノード上で作成された各キューはに複製されます

1熱

1答えて

RabbitListenerバインディングキューと複数のエクスチェンジ

RabbitListenerアノテーションを使用してキューを複数のエクスチェンジにバインドできるようになっていますが、これまでに失敗しています。私が今持っていることは次のとおりです。 @RabbitListener(bindings = @QueueBinding(value = @Queue( value = "${subscriber.queueInbound}", du