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> 

때 자동 시작 = "true"로 우리는 각 아웃 바운드 게이트웨이에 대한 replyListener 스레드를 참조하십시오. 이 추가로드 및 자원 소비를 제거하기 위해 autostart = "false"로 변경하고 beforeStep 및 afterStep 메소드에서 게이트웨이를 시작 및 중지하는 분할 단계에 대한 단계 리스너를 추가했습니다. 서버 시작시 replyListener 스레드는 예상대로 존재하지 않습니다. 단계 실행 도중에 나타나지만 아웃 바운드 게이트웨이에서 중지하기 위해 호출 한 후에는 제거되지 않습니다 (장기간 기다린 후에도 제거됨).

replyListener를 정리하려면 다른 것이 필요합니까?

Answer 1

확인 하시겠습니까? 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 로컬 캐시를 기반으로하며 doInitialize() 컨테이너 인 경우 !this.running 인 경우 채워집니다.

로직을 어떻게 든 변경해야한다고 생각하면 자유롭게 JIRA을 붙이십시오.