バネ統合ブリッジ直接チャネル待ちチャネル

Question

ユニットテスト時に、このチャネルへのメッセージフロー量の正確性をチェックしたいので、私はSpring Integrationデフォルトチャネルを待ち行列に入れたチャネルにブリッジしようとします。

<int:filter input-channel="prevChannel" output-channel="myChannel"> 
<int:bridge input-channel="myChannel" output-channel="aggregateChannel"> 
// the reason I have above bridge is I want to check the amount of message after filter. 
// I cannot check prevChannel since it is before filtering, and I cannot check aggregateChannel 
// because it has other processing branch 

// in test xml I import above normal workflow xml and added below configuration to 
// redirect message from myChannel to checkMyChannel to checking. 


<int:bridge input-channel="myChannel" 
      output-channel="checkMyChannel"/> 

<int:channel id="checkMyChannel">  
    <int:queue/> 
</int:channel> 

私はユニットテスト にcheckMyChannelをautowiredが、checkMyChannel.getqueuesize（）は常に0

は私が間違っていたがSTHされる戻り？

Answer 1

を固定してしまった、私はこの1つは、私の場合のために競合状態がいるのであり、助け

How to test Spring Integration パブリッシュ・サブスクライブチャンネルであることをmyChannelを宣言しなければなりません。 "複数の加入者を持つ通常のチャンネルはラウンドロビンします..."

Answer 2

あなたは私たちとテストケースを共有しませんでした。私たちは全体像を持っていません。そこに競争状態があるように見えます。 getqueuesize()というアサーションを開始する前に、誰かがcheckMyChannelからすべてのメッセージをポーリングします。

私たちのテストでは、そのような場合には<poller>を使用しません。手動でPollableChannel.receive(timeout)を使用します。これは