spring-amqp

0熱

1答えて

にバインド、送信していない私は、次のようにメッセージを送信しようとした： rabbitTemplate.convertAndSend("my.exchange", "my.queue", "Test Message"); を、次のようにメッセージを受信しようとした： @RabbitListener(bindings = @QueueBinding(value = @Queue(value =

0熱

1答えて

Spring AMQP Auto Scaling Group

私はトピック交換を使ってSpring AMQPとSpring Cloud Streamの研究を行ってきました。私がAWS自動スケーリンググループにそのアプリを持っていれば、アプリの余分なインスタンスが同じ交換機に加入して重複メッセージを受け取るでしょうか？

1熱

1答えて

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

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

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熱

2答えて

はSpringBootApplication前springboot application.ymlファイルの値を解析する方法をお探しすることは

を初期化され、次のように私の問題は、次のとおりです。私はSSLを使用していることRabbitMQのインスタンスに接続するためのスプリングAMQPを使用しています。残念ながら、春のAMQPは現在、全長のamqps URIをサポートしておらず、優先度リストでのサポートの追加は高くありません（問題：https://github.com/spring-projects/spring-boot/issue

0熱

1答えて

スプリング無し出力チャネル又はreplyChannelヘッダ利用可能

ouboundゲートウェイと春AMQPを統合する困難に直面 .. エラー：org.springframework.messaging.core.DestinationResolutionException：によって引き起こさなし出力チャネル又は利用可能replyChannelヘッダ統合XML <int:gateway id="outboundGateway" service-interface

0熱

1答えて

Spring AMQPとCachingConnectionFactory

2つのアドレスを持つCachingConnectionFactoryを持っている場合、どのサーバーに接続しているかをいつどのように知ることができますか？手動で一方から他方へ手動で変更する最善の方法は何でしょうか？ /** Retrieve address of peer. */ InetAddress getAddress(); /** Retrieve port number of pee

0熱

1答えて

ばねAMQP、アウトバウンド（JMS-アウトバウンドゲートウェイのような）異なるTHEADからの応答を生成するために、ゲートウェイ

問題ステートメント：（JMS-アウトバウンドゲートウェイのような別のスレッドからの応答を生成するスプリングAMQP、アウトバウンドゲートウェイ異なる待ち行列を有する場合、相関キーを使用して要求/応答を相関させる）。メッセージをこの例と関連付けることができません。 Spring統合 <int:gateway id="outboundGateway" service-interface="com.