アプリケーションによって生成された識別子を使用したAMQPカスタムメッセージの相関

Question

スプリング統合を使用してアウトバウンドゲートウェイ用にアプリケーションによって生成された識別子を使用したAMQPカスタムメッセージの相関。

アウトバウンドゲートウェイのメッセージとappによって生成されたIDを関連付ける必要があるという要件があります。これは、実際のメッセージ処理が外部システムで行われ、要求に対する応答が外部システムからのポストとして行われるしたがって、amqp_correlationデータに依存することはできません。

これを実行すると、偉大なステップが得られます。ソリューションウサギテンプレート

型AMQPのメッセージを作成における相関キーを設定

1. を試み

   は、いくつかの生成された値とテンプレートに設定correleationキーでヘッダ名を設定

2. カスタムヘッダー名のAMQP発信ゲートウェイにheader-mapperを提供します。

結果が

ウサギのテンプレートは要求に設定された値を使用していない、しかしそれは、独自の値を生成し、カスタムヘッダーをマッピングすることができた/

Answer 1

にメッセージを返信する。このためnew feature JIRA Issueを開いてください。

correlationIdが一意であることを確認することは、あなたの責任となります。

テンプレートをサブクラス化してsendToRabbitを上書きすることで回避できます。そこにcorrelationIdを設定します。テンプレートのcorrelationId（理想的には別のヘッダーのメッセージにありますが、おそらくMap）を保存し、そのヘッダーもサーバーに返さなければなりません。

protected void sendToRabbit(Channel channel, String exchange, String routingKey, boolean mandatory, 
     Message message) throws IOException { 
    // fix up properties 
    super.doSend(...); 
} 

また、インバウンド要求の適切なcorrelationIdを復元するには、onMessage()をオーバーライドする必要があります。