Randy Prager created AMQ-5084:
---------------------------------
Summary: InterruptedIOException when attempting to re-create a
Topic or Queue after previously closing it
Key: AMQ-5084
URL: https://issues.apache.org/jira/browse/AMQ-5084
Project: ActiveMQ
Issue Type: Bug
Components: JMS client
Affects Versions: 5.9.0
Environment: windows 8, java 7
Reporter: Randy Prager
We can successfully create a queue or topic. However if we then close the
connection, session and queue/topic and then attempt to re-create the queue or
topic we get an exception.
When we attempt to re-create (after closing it) using the following:
{code}
QueueSession session = (
(QueueConnection)connection).createQueueSession(transacted,Session.AUTO_ACKNOWLEDGE);
{code}
throws the following exception:
{noformat}
16:29:12,748 INFO [pool-3-thread-1] DefaultQueueProvider subscription
name=dynamicQueues/MX.TEST
16:29:12,757 ERROR [pool-3-thread-1] JMSFactory class
javax.jms.JMSException
javax.jms.JMSException: java.io.InterruptedIOException
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at
org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1277)
at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1269)
at org.apache.activemq.ActiveMQSession.<init>(ActiveMQSession.java:252)
at
org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:317)
at
org.apache.activemq.ActiveMQConnection.createQueueSession(ActiveMQConnection.java:1242)
.... redacted stack trace ...
at java.lang.Thread.run(Thread.java:744)
Caused by: java.io.InterruptedIOException
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:102)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
at
org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1275)
... 16 more
{noformat}
--
This message was sent by Atlassian JIRA
(v6.2#6252)