You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by shafina <sh...@wipro.com> on 2011/01/21 16:43:45 UTC

java.io.InterruptedIOException while posting message

Hi, 

While posting a message using activemq thread gets interrupted and following
exception is thrown 

javax.jms.JMSException: java.io.InterruptedIOException 
        at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) 
        at
org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1259) 
        at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1251) 
        at
org.apache.activemq.ActiveMQSession.doClose(ActiveMQSession.java:642) 
        at
org.apache.activemq.ActiveMQSession.close(ActiveMQSession.java:633) 
        at
com.kronos.ngd.platform.base.messaging.api.MessagingServiceImpl.postMessage(MessagingServiceImpl.java:490) 
        at
com.kronos.ngd.platform.base.messaging.api.MessagingServiceImpl.post(MessagingServiceImpl.java:439) 
        at
com.kronos.ngd.application.base.biometrics.api.BiometricAppServiceImpl.postIdentificationMessage(BiometricAppServiceImpl.java:3469) 
        at
com.kronos.ngd.application.base.biometrics.api.BiometricAppServiceImpl$EmployeeIdentifier.run(BiometricAppServiceImpl.java:3415) 
        at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441) 
        at
java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) 
        at java.util.concurrent.FutureTask.run(FutureTask.java:138) 
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) 
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) 
        at java.lang.Thread.run(Thread.java:619) 
Caused by: java.io.InterruptedIOException 
        at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:105) 
        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:1257) 
        ... 13 more 
Caused by: java.lang.InterruptedException 
        at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1199) 
        at
java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:312) 
        at
java.util.concurrent.LinkedBlockingQueue.put(LinkedBlockingQueue.java:294) 
        at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:95) 
        ... 16 more 

After this exception the session used for posting message is closed. On 
trying to use the session agan below exception is thrown. 
javax.jms.IllegalStateException: The Session is closed Jan 13 15:26:28
127.0.0.1 at
org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:722) 
Jan 13 15:26:28 127.0.0.1 at
org.apache.activemq.ActiveMQSession.createProducer(ActiveMQSession.java:922) 

Why while posting message i am getting this nterrupted exception?
Is there any reason why the session is getting closed after Interrupted
exception? 
Since we are re using the session in our application is there a way to know
the state of the session? If the session is closed or active? 
-- 
View this message in context: http://activemq.2283324.n4.nabble.com/java-io-InterruptedIOException-while-posting-message-tp3229933p3229933.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.