Z wdzięcznością zatrzymaj DefaultMessageListenerContainer o wartość receiveTimeout = -1
Czy ktoś może wskazać mi sposób na zatrzymanie z powodzeniem DefaultMessageListenerContainer na wiosnę, który jest zdefiniowany za pomocąreceiveTimeout = -1 (tzn. używa blokującej wersji javax.jms.MessageConsumer # receive)?
Właściwie próbowałem metod stop () i shutdown () DMLC, ale wątek konsumencki utknął na wywołaniu receive ().
"heartBeatContainer-1" prio=6 tid=0x0304d800 nid=0x1d20 in Object.wait() [0x037ef000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <0x22c48ab0> (a java.lang.Object)
at java.lang.Object.wait(Object.java:485)
at org.apache.activemq.SimplePriorityMessageDispatchChannel.dequeue(SimplePriorityMessageDispatchChannel.java:87)
- locked <0x22c48ab0> (a java.lang.Object)
at org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:452)
at org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:504)
at org.springframework.jms.connection.CachedMessageConsumer.receive(CachedMessageConsumer.java:70)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:430)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:310)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1069)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1061)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
at java.lang.Thread.run(Thread.java:662)
Nie mogę zamknąć połączenia, ponieważ są inni słuchacze, którzy powinni nadal korzystać z wiadomości.