問題タブ [spring-amqp]

2 つの rabbitMQ ノードでクラスターを作成しました。rabbit1 ノードと rabbit2 ノードの構成は次のとおりです。

2> ノード タイプ rabbit1 - ディスク ノード rabbit2 - ram ノード 3> プロデューサー プログラムとコンシューマー プログラムは rabbit2 ノードに配置されます (つまり、ram ノード)

これに関する助けに感謝します。

RabbitMQ クラスタリングを設計する際に、Spring AMQP で HAProxy を使用するのは何ですか? それはSpring AMQPの一部ですか、それとも外部を構成する必要がありますか? 前もって感謝します。

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

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

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

前もって感謝します！

Spring Integration と Spring Integration AMQP は初めてです。

次のコードがあります。

セットアップは次のとおりです。

メッセージが inbound-channel-adapter によって取得されたときにヘッダーが失われることを除いて、すべてが正常に機能しています。

同様に、メッセージが outbound-channel-adapter を使用して取引所に送信されると、「ストア」と呼ばれる強化されたヘッダーも失われます。

これは、inbound-channel-adapter によって取得される前のメッセージの外観です。

これは、同じメッセージがプロセス全体を処理する方法です (ヘッダーがないことに注意してください)。

Spring Integration と Spring Integration AMQP に使用しようとしている次の XML ペイロードがあります。

xpath-splitter を使用してメッセージを分割しています。

私は正常に動作し、メッセージは次のペイロードを使用して 3 つの新しいメッセージに分割されています。

この手順の後、メッセージは次のセットアップを使用して集約されます。

最後のステップとして、メッセージはこの outbound-channel-adapter を使用して取引所に送信されています。

残念ながら、このペイロードのようなものになってしまうため、何か問題が発生します。XML 形式のままにしておく必要があります。

Spring AMQP を使用して RabbitMQ で非同期呼び出しを実行しようとしています。Spring amqp を使用して、replyqueue、correlationId、(プロパティ) を構成する方法を教えてください。

ヘッダーにあるように、Esper と RabbitMQ を組み合わせてプロジェクトをビルドする際に問題があります。したがって、Esperio (バージョン 4.10) の amqp アダプターを使用する必要があります。

マニュアルの基本から始めましたが、何らかの理由でクエリが適切に評価されていません。amqp アダプターの宣言で「EventBusSink」と「EventBusSource」を切り替える必要があることはすでにわかっています (「出力ストリームが定義されていません」などのビルド エラー)。

次のように Spring AMQP を使用して、Rabbitmq に 2 つのキューを設定しています。

Esper と amqp アダプターを次のように構成します。

構成を設定し、1 つのメソッド (コンストラクターまたは init メソッド) で複数のステートメントを発行すると、すべてが正常に機能します。しかし、最初にカスタム構成 (アダプターを使用) で esper を開始し、後のフェーズでステートメントを発行する (そして、後でそれらのステートメントに一致するイベントを送信する) と、ステートメントと一致するものは何もありませんでした。それにもかかわらず、同じ esperProvider (コードでは epService) を使用します。ステートメントを発行するメソッドで構成部分を複製すると、アダプターが既に存在するという例外が発生します。

クエリの例は次のとおりです。

そして送信されたイベント：

AEsper には、実行時にステートメントを公開するための制限はありますか?

ありがとう！

ジャナ

以下のように、同期メッセージングにSpring AMQPを使用するコードがあります。私のシナリオは、プロデューサーが応答を期待しているメッセージを送信するときです。したがって、同期メッセージの場合に応答を返す方法について、誰でも助けることができます。

handleMessage()非同期メッセージングの場合に使用できることがわかりました。しかし、上記の API を使用して、同期メッセージングの場合に応答を返す方法は? これについて私を助けてもらえますか？

前もって感謝します。