You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/10/08 14:46:58 UTC

svn commit: r582806 - in /incubator/qpid/trunk/qpid/java/client/src: main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java test/java/org/apache/qpid/test/unit/client/temporaryqueue/TemporaryQueueTest.java

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