activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eric-AWL <eric.vinc...@atosorigin.com>
Subject 2 connections and InterruptedException
Date Tue, 10 Nov 2009 17:30:55 GMT

Hi

With ActiveMQ 5.2.

I have one process that is connected to one embedded broker and
simultaneously to an other distant broker (TCP)

When the link with the TCP distant broker is broken, I want to close
properly all my Consumer ressources even for my embedded broker

I receive an InterruptedException on the "close" of a consumer associated
with this embbeded broker. 

Here are the java trace log

2009/10/29;11:08:57:167;ERR;CService;ADM(tqerdp31v);NOCP2@@@ADM_STA[[[######]]];NA;BUSACT-0000;(Exception)
javax.jms.JMSException: java.io.IOException
        at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
        at
org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1216)
        at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1208)
        at
org.apache.activemq.ActiveMQSession.asyncSendPacket(ActiveMQSession.java:1762)
        at
org.apache.activemq.ActiveMQMessageConsumer.close(ActiveMQMessageConsumer.java:594)
        at
atosbus.transport.jms.CJMSListenerChannel$CJMSObjects.close(CJMSListenerChannel.java:177)
        at
atosbus.transport.jms.CJMSListenerChannel.close(CJMSListenerChannel.java:419)
        at
atosbus.transport.jms.CJMSListenerChannel.close(CJMSListenerChannel.java:439)
        at
atosbus.transport.jms.CJMSListenerChannel.stopListener(CJMSListenerChannel.java:339)
        at
atosbus.core.service.CListenerContext.stopListener(CListenerContext.java:352)
        at
atosbus.core.service.CListenerContext.removeInternalsListeningRight(CListenerContext.java:804)
        at
atosbus.core.service.CService.removeInternalsListeningRight(CService.java:2087)
        at
atosbus.core.system.CComponent.disallowsTransportListening(CComponent.java:2603)
        at
atosbus.core.system.CInstance.removeInternalsListeningRight(CInstance.java:638)
        at
atosbus.core.system.CComponent.signalRecoveringState(CComponent.java:223)
        at
atosbus.transport.CNetworkConnections.brokenNetworkCbk(CNetworkConnections.java:194)
        at
atosbus.transport.jms.CJMSConnection.onException(CJMSConnection.java:117)
        at
org.apache.activemq.ActiveMQConnection$4.run(ActiveMQConnection.java:1779)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
        at java.lang.Thread.run(Thread.java:595)
Caused by: java.io.IOException
        at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:45)
        at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:103)
        at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
        at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
        at
org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1214)
        ... 19 more
Caused by: java.lang.InterruptedException
        at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1097)
        at
java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:307)
        at
java.util.concurrent.LinkedBlockingQueue.put(LinkedBlockingQueue.java:240)
        at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:92)
        ... 22 more

I'm not sure that the "interrupt" is not done by on of my process. But I
don't interrupt any ActiveMQ thread myself.

Do you know if this behaviour is the good one ?

Eric-AWL
-- 
View this message in context: http://old.nabble.com/2-connections-and-InterruptedException-tp26287342p26287342.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message