[
https://issues.apache.org/jira/browse/AMQ-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15029829#comment-15029829
]
ASF subversion and git services commented on AMQ-3529:
------------------------------------------------------
Commit 0a12bcb928f151b5ace9a0cffc34ec717b6a8e9c in activemq's branch
refs/heads/master from [~gtully]
[ https://git-wip-us.apache.org/repos/asf?p=activemq.git;h=0a12bcb ]
https://issues.apache.org/jira/browse/AMQ-2191
https://issues.apache.org/jira/browse/AMQ-3529 - rework fixes to remove
uncertanty from dealing with intettuptedexception. Sync requests will trap
interrupts that ocurr while waiting for responses and fail the connection with
an interruptedioexception. Interrupts pending before requests will be
suppressed, allowing possible clean shutdown. It is not safe to replay openwire
ops b/c they are not idempotent, the only safe option is to have a teardown of
the broker side state from a close
> Calling Thread.interrupt while in MessageConsumer#receive(timeout) generates
> java.io.InterruptedIOException and leaks Connection
> ---------------------------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-3529
> URL: https://issues.apache.org/jira/browse/AMQ-3529
> Project: ActiveMQ
> Issue Type: Bug
> Components: JMS client
> Affects Versions: 5.5.0
> Reporter: Philippe Mouawad
> Assignee: Timothy Bish
> Fix For: 5.6.0
>
> Attachments: AMQ3529Test.java
>
>
> Hello,
> While running tests with JMeter and calling stop while test is running, I see
> that Transport thread stays open and all close() on Connection,
> MessageConsumer, Session calls fails with exception:
> 2011/10/08 17:16:59 ERROR - jmeter.protocol.jms.client.ReceiveSubscriber:
> Error during close: javax.jms.JMSException: java.io.InterruptedIOException
> at
> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
> at
> org.apache.activemq.ActiveMQConnection.doSyncSendPacket(ActiveMQConnection.java:1342)
> at
> org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:660)
> at org.apache.jmeter.protocol.jms.Utils.close(Utils.java:65)
> at
> org.apache.jmeter.protocol.jms.client.ReceiveSubscriber.close(ReceiveSubscriber.java:236)
> at
> org.apache.jmeter.protocol.jms.sampler.SubscriberSampler.threadFinished(SubscriberSampler.java:305)
> at
> org.apache.jmeter.threads.JMeterThread$ThreadListenerTraverser.addNode(JMeterThread.java:579)
> at
> org.apache.jorphan.collections.HashTree.traverseInto(HashTree.java:986)
> at org.apache.jorphan.collections.HashTree.traverse(HashTree.java:969)
> at
> org.apache.jmeter.threads.JMeterThread.threadFinished(JMeterThread.java:554)
> at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:328)
> at java.lang.Thread.run(Thread.java:680)
> Caused by: java.io.InterruptedIOException
> at
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:102)
> at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
> at
> org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)
> at
> org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:91)
> at
> org.apache.activemq.ActiveMQConnection.doSyncSendPacket(ActiveMQConnection.java:1329)
> ... 10 more
> I opened an issue in JMeter with all details but I think issue is in
> ActiveMQ, see:
> https://issues.apache.org/bugzilla/show_bug.cgi?id=51997
> Issue contains a Test Plan, and all details.
> Regards
> Philippe
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
