問題タブ [spring-rabbit]

サンプルの指示に従っています。これは、 http : //static.springsource.org/spring-amqp/docs/1.2.x/reference/html/sample-apps.htmlStock Tradingで要求/応答メッセージングを使用する方法を概説しています。 #d4e742spring-amqp

たまたま返信メッセージを送信できるメッセージ駆動型 POJOであるクラスを見ると、ServerHandlerMessageProperties を注入できる場所がわかりません。content-type

このサンプルを微調整して、単純な文字列を装った xml メッセージを返したいのですがServerHandler、返信を RabbitMQ に投稿すると、次のようになります。

そして最終的に（私の推測では）これを読んでいるはずの私のクライアントは、オブジェクトがcontent_type正しく設定されていないためにオブジェクトを解析できずapplication/json、ユースケースが失敗したためnull、返信として返されます。

Q) spring-amqp Request/Reply Messaging で応答の content-type を設定する方法を知っている人はいますか?

アップデート#1

jsonMessageConverterQ) おそらく、requestQueue からメッセージを読み取るためにのみ使用され、responseQueue に返信を戻したい場合には使用されないようにする必要があるかもしれません。これは、現在の appContext.xml ファイルからの抜粋です。

spring-rabbit を使用して、RabbitMQ 経由でメッセージを送信する必要がある 2 つの別個の Java アプリがあります。プロデューサーであるアプリでは、キューに送信される前に Java オブジェクトを JSON メッセージに変換するJsonMessageConverterためのメッセージ コンバーターとして使用しています。RabbitTemplate

コンシューマーである他のアプリでは、JSON メッセージを Java オブジェクトに変換したいと考えています。SimpleMessageListenerContainerカスタムで使用してみましたが、キューから sMessageListenerを取得できますが、Messageそれらを JSON から Java オブジェクトに変換する方法がわかりません。

JsonMessageConverterRabbitMQ から非同期でメッセージを消費する場合、どのように使用すればよいですか?

POJO を使用して spring amqp を介して基本的な要求/応答メッセージングをセットアップしました。これらは JSON メッセージコンバーターを介して RabbitMQ で交換されます。

これまでの応答 pojo のペイロードは単純な文字列でしたが、今では画像を返信する必要があります。

Q1) これを処理する最善の方法は何ですか? JSON メッセージのペイロード文字列として画像を base64 エンコードする必要がありますか?

Q2) 単純に画像を BytesMessage として返すことは可能ですか?

Q2.a) spring-amqp は、POJO を返すリスナーと BytesMessage を返すリスナーの 2 つの別個のリスナーを処理できますか? 私はそうは思わないでしょうが、ここに私が求めているものの周りの疑似コードがあります:

Q2.b) または ... MessageListener がオブジェクトを返す場合 (POJO の場合もあれば、BytesMessage の場合もある) ... spring-amqp フレームワークは、実行時にそれに応じて調整して、シリアル化された POJO を送り返すことができますか?場合によっては json として、場合によっては BytesMessageをそのままにしますか?

私はRabbitMQを学んでいます。彼らのウェブサイトで基本的な rabbitmq チュートリアルから始めましたが、残念ながら次のエラーのためにコンパイルできません。

エラー: 「タイプ ConnectionFactory のメソッド newConnection(Address[]) は、引数 () には適用できません」

接続 connection = factory.newConnection();

エラー: タイプ ConnectionFactory のメソッド newConnection(Address[]) は、引数 () には適用できません

私が持っているMavenの依存関係は次のとおりです。

ここで私は正確に何を間違っていますか？どんな助けでも大歓迎です！

ありがとう！

プロデューサーから、RabbitMQ Exchange にメッセージを送信する必要があります。このメッセージには、特定の属性 (キュー名など) が含まれます。この属性に基づいて、このメッセージを送信するキューを動的に決定する必要があります。[Exchange からバインドするキュー、この特定のメッセージを送信するキュー]。

Spring 統合を使用して、RabbitMQ Exchange に到着するメッセージを傍受する方法はありますか?現在、次の Spring 統合構成ファイルがあります。

Exchange メッセージを取得し、メッセージを smsQueue、emailQueue などのキューにルーティングする Bean を作成する方法がわかりません。

提案と返信をありがとう。

http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit- 1.0.xsd

Spring AMQP 1.2 リリースを使用して、RabbitMQ ブローカーのパフォーマンス テストに取り組んでいます。誰でも同じ手順を説明でき、プロデューサーとコンシューマーの両方のクライアントとして Java を使用しています。

auto-startup="true" を使用しています すべてが正常に機能します。Controlbus を使用してアダプターを開始/停止しています。auto-startup="false" を変更してから、制御バスを使用してアダプターを開始する必要があります。auto-startup="false" は、プロセスを停止させます (稼働していません)。

どうすればプロセスを実行できますが、inbound-channel-adapter を停止するだけです。

Spring-AMQP の優れた機能の 1 つは、ブローカーがダウンしてから復帰したときに、Spring アプリケーションをメッセージ ブローカーに再接続するために必要なロジックを実装しているように見えることです。

私が探しているのは、このような切断/再接続イベントがアプリケーション内でいつ発生したかを検出するための推奨される方法です。

これまでに思いついた最良の方法は、定期的にコネクション ファクトリからチャネルを取得しようとするポーリングのようなメカニズムです。

前もって感謝します！