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.