Author: arnaudsimon
Date: Mon Oct 8 05:46:57 2007
New Revision: 582806
URL: http://svn.apache.org/viewvc?rev=582806&view=rev
Log:
fixed issue with temporary queues as the consumer was not closed when cancel
operation returned
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/temporaryqueue/TemporaryQueueTest.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java?rev=582806&r1=582805&r2=582806&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Mon Oct 8 05:46:57 2007
@@ -172,6 +172,8 @@
{
((AMQSession_0_10)
getSession()).getQpidSession().messageStop(getConsumerTag().toString());
((AMQSession_0_10) getSession()).getQpidSession().sync();
+ // confirm cancel
+ getSession().confirmConsumerCancelled(getConsumerTag());
try
{
((AMQSession_0_10) getSession()).getCurrentException();
Modified:
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/temporaryqueue/TemporaryQueueTest.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/temporaryqueue/TemporaryQueueTest.java?rev=582806&r1=582805&r2=582806&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/temporaryqueue/TemporaryQueueTest.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/temporaryqueue/TemporaryQueueTest.java
Mon Oct 8 05:46:57 2007
@@ -42,12 +42,11 @@
protected void setUp() throws Exception
{
super.setUp();
- TransportConnection.createVMBroker(1);
}
protected void tearDown() throws Exception
{
- TransportConnection.killAllVMBrokers();
+ super.tearDown();
}
protected Connection createConnection() throws Exception
