2016-08-23 7 views
0

私はバネ統合チェーンでフックしたい簡単なJMSトピックリスナーを持っています。
基本的に、JMSメッセージがリスナーで受信されると、チェーンのチャネルにプッシュされる必要があります。最終的にメッセージは処理され、消費されるアウトバウンドチャネルアダプタにプッシュされます。
Spring Integrationのドキュメントでは、非同期ゲートウェイの使用について言及していますが、Futuresを使用しています。 メッセージをチャンネルに入れるだけの簡単な方法はありませんか?
あなたが指すことができる例があれば、それは素晴らしいことでしょう。
おかげ
よろしく
マーティンチャネル内でのメッセージの非同期プッシュ(スプリング統合)

答えて

1

あなたはリスナースレッドのフローを実行したい場合は、単に通常のゲートウェイ(ない非同期1)を使用します。何らかの理由でフローが失敗した場合、メッセージはロールバックされます。

「火を忘れる」場合は、ゲートウェイからのリクエストチャネルをExecutorChannelとすることができます - hereを参照してください。

+0

おかげさまでゲーリーが迅速に対応しました! –

+0

リスナースレッドで応答が少なくとも今はOKです。ゲートウェイ構成はインタフェースのみを使用します。自分の実装を定義する必要があります。私はそれをどのように指定しますか?ありがとう –

+0

フレームワークは実装を生成します(引数を 'Message 'にラップします - [documentation](http://docs.spring.io/spring-integration/reference/html)を参照してください。 /messaging-endpoints-chapter.html#gateway))。さらに操作を行いたい場合は、 ''をストリームに追加します。 –

関連する問題