JmsOutboundGateway：手動起動と停止

Question

約100個のジョブに分割された約75の分割ステップを持つアプリケーションがあります。

<int-jms:outbound-gateway 
    id="outbound-gateway_1" 
    auto-startup="true" 
    connection-factory="jmsConnectionFactory" 
    request-channel="jms.requests_1" 
    request-destination="jms.requestsQueue" 
    reply-channel="jms.reply_1" 
    reply-destination="jms.repliesQueue" 
    receive-timeout="${timeout}" 
    correlation-key="JMSCorrelationID" > 
    <int-jms:reply-listener receive-timeout="1000"/> 
</int-jms:outbound-gateway> 

autostart = "true"の場合、各送信ゲートウェイのreplyListenerスレッドが表示されます。この余分な負荷とリソース消費を取り除くために、autostart = "false"に変更し、beforeStepおよびafterStepメソッドでゲートウェイを開始および停止するパーティション・ステップのステップ・リスナーを追加しました。サーバーの起動時に、replyListenerスレッドは期待どおりに存在しません。ステップ実行中に表示されますが、発信ゲートウェイで停止するようにコールした後は削除されません（長時間待った後でも）。

replyListenerをクリーンアップする必要がありますか？

Answer 1

OK、どういう意味ですか。 DefaultMessageListenerContainer.AsyncMessageListenerInvoker.executeOngoingLoop()

ポイントで

while ((active = isActive()) && !isRunning()) { 
    if (interrupted) { 
     throw new IllegalStateException("Thread was interrupted while waiting for " + 
       "a restart of the listener container, but container is still stopped"); 
    } 
    if (!wasWaiting) { 
      decreaseActiveInvokerCount(); 
    } 
    wasWaiting = true; 
    try { 
     lifecycleMonitor.wait(); 
    } 
    catch (InterruptedException ex) { 
     // Re-interrupt current thread, to allow other threads to react. 
     Thread.currentThread().interrupt(); 
     interrupted = true; 
    } 
} 

がlifecycleMonitor.wait();あるとIllegalStateExceptionのメッセージに注意を払う：のようにそれは見えます。

このようなデザインの目的はわかりませんが、そのままで生きていなければ、選択肢はありません。

start()のロジックは、this.pausedTasksローカルキャッシュに基づいています。これは、コンテナ!this.runningの場合はdoInitialize()の間に埋められます。

どういうわけか論理を変えなければならないと思ったら、JIRAをつけてください。