Spring統合：JMSからの読み取り - >メッセージの処理 - > DB内での持続

Question

私はSpring Integrationを使用してJMSからメッセージを読み取り、処理して戻り値のvoidを持つ独自のdbPersistorのpersistメソッドを使用してデータベースに保持します。私は、JMSに公開されたメッセージがdbに正常に保持されていることを検証するためのテストケースを書きました。このテストのために次のように私のSIおよびJMS構成がある -

<int:poller fixed-delay="500" default="true"/> 

<int:channel id="inputChannel"> 
    <int:queue/> 
</int:channel> 
<int:channel id="errorChannel"> 
    <int:queue/> 
</int:channel> 
<jms:message-driven-channel-adapter id="jmsInboudAdapter"   
    connection-factory="connectionFactory" destination-name="MessageQueue" 
    channel="inputChannel" error-channel="errorChannel" transaction-manager="dbTxManager"          
    acknowledge="transacted"/> 

<int:chain id="handlerChain" input-channel="inputChannel"> 
    <int:service-activator ref="jmsMessageHandler" method="handleMessage" /> 
    <int:service-activator ref="dbPersistor" method="persist" /> 
</int:chain> 

その後、私は次の操作を行うテストで -

• jmsTemplate.send（）
• verifyMessageWasPersistedToDB

この私はちょうど1つのメッセージをdbに公開するとうまくいく。しかし、複数のメッセージを公開するためにjmsTemplate.send（）をループすると、メインスレッドはSIスレッドがまだ実行されている間に操作を完了し、DB内のメッセージを検証しようとし、メッセージの一部がまだ永続化されていないため失敗します。私の質問は -

1. メインスレッドがSIスレッドが終了してからverifyメソッドを呼び出すのを待つようにするにはどうすればよいですか？
2. db例外とロールバックの場合、失敗したメッセージが元のキューに戻ってきたことを確認するにはどうすればよいですか？

おかげ AJ

Answer 1

1. inputChannelキュー・チャネルであってはならない - メッセージがキューに挿入されたときにJMSトランザクションはコミットされます - DBトランザクションは、の範囲で行われることはありませんJMSトランザクションこれにはダイレクトチャネルを使用する必要があります（ポーラーと<queue/>を削除してください）。 the documentation on transactions in Spring Integrationを参照してください。

2. 結果をデータベースでポーリングする必要があります。あなたはおそらくインターセプターといくつかのCountDownLatchを追加することができますが、結果が出るまで、または時間があるまでDBをポーリングする方が簡単です。