qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject 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
Date Mon, 08 Oct 2007 12:46:58 GMT
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



Mime
View raw message