spring-integration-amqp

0熱

1答えて

Spring Integrationを使用してmsgをjson形式でキューに入れる方法AMQP

現在、私はjson形式のキューにメッセージを入れようとしています。それ以下では私のコードスニペットですが、うまくいきません。 return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, NOTE_INCOMING_QUEUE) .concurrentConsumers(2)) .transf

1熱

1答えて

RabbitMQ + Spring統合。キューサイズ1は、のみ削除するとき、私は今かのうである場合のRabbitMQと春の統合でこのアイデアを実装したいと思い

オーバーライド： 1つのキュー、1つのメッセージのcapatityと。コンシューマはこのメッセージを要求します。キューに存在する場合はメッセージが配信され、存在しない場合はnullまたはエラーが返されます。このメッセージ（キューに存在する場合）は、ダウンロードされたために削除されません。プロデューサが新しいメッセージをキューに入れたときにのみ削除されます。よろしくお願いいたします。このような

3熱

1答えて

私はint型で宣言している別のメッセージ

を発行するための2つのアウトバウンド・チャネル・アダプタを宣言する方法：（異なる <int:chain input-channel="InputChannel" output-channel="Channel"> <int:transformer method = "transform" > <bean class="com.sampleconverter" />

1熱

1答えて

Spring RecoveryCallbackでメッセージの詳細を取得

私はRabbitMQにメッセージを公開していますが、RabbitMQがダウンしたときにエラーを追跡したいと思います。復旧コールバックでRetryTemplateを追加しましたが、復旧コールバックはこのメソッドを提供します。getLastThrowable() RabbitMQがダウンしたときに失敗したメッセージの詳細を提供する方法がわかりません。（ドキュメントごとに「RecoveryCallba

1熱

1答えて

バネ積分のxml構成で使用されるとき、「int」は何を意味しますか？

私は現在、春の統合のトピックで読んでいます。 Spring統合のXML構成で使用される表記法/接頭辞 - > "int"を使用しています。 <int:channel id="errorChannel"> <int:queue capacity="500"/> 誰もがそれを理解する上で私を助けることができますか？またどこかで私は 'si'が使われているのを見たことがある。これらのプレフィックス

0熱

1答えて

spring messaging xml configの同等のJava Config

私はrabbitMQを使用してSpringバッチリモートチャンクを実装しようとしています。 I以下のINBOUNDため、この <int:channel id="requests"/> <int:channel id="replies"/> <int-jms:message-driven-channel-adapter id="jmsIn" destination-name="req

1熱

1答えて

Spring Cloud StreamとRabbitMQヘルスチェック

Spring Cloud Stream RabbitとEureka Discovery Clientを使用した簡単なSpring Bootアプリケーションがあります。アプリケーションはEureka Serverと一緒にうまく動作し、RabbitMQを介したメッセージングも機能しています。私は春のブート管理サーバーをスピンアップ場合でも、アプリケーションはヘルスチェックの失敗の記録を開始： 2017