You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2015/11/26 15:03:28 UTC
svn commit: r1716658 - in /qpid/java/branches/6.0.x: ./
systests/src/test/java/org/apache/qpid/client/session/QueueDeleteTest.java
Author: orudyy
Date: Thu Nov 26 14:03:28 2015
New Revision: 1716658
URL: http://svn.apache.org/viewvc?rev=1716658&view=rev
Log:
QPID-6874, QPID-6744: close the consumer used to retrieve a message when done with it, otherwise the session will likely see a resource-deleted execution exception before failing to create another consumer on the then-deleted queue
------------------------------------------------------------------------
Merged from trunk with command:
svn merge -c r1715445 https://svn.apache.org/repos/asf/qpid/java/trunk
Modified:
qpid/java/branches/6.0.x/ (props changed)
qpid/java/branches/6.0.x/systests/src/test/java/org/apache/qpid/client/session/QueueDeleteTest.java
Propchange: qpid/java/branches/6.0.x/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 26 14:03:28 2015
@@ -9,4 +9,5 @@
/qpid/branches/java-broker-vhost-refactor/java:1493674-1494547
/qpid/branches/java-network-refactor/qpid/java:805429-821809
/qpid/branches/qpid-2935/qpid/java:1061302-1072333
+/qpid/java/trunk:1715445
/qpid/trunk/qpid:796646-796653
Modified: qpid/java/branches/6.0.x/systests/src/test/java/org/apache/qpid/client/session/QueueDeleteTest.java
URL: http://svn.apache.org/viewvc/qpid/java/branches/6.0.x/systests/src/test/java/org/apache/qpid/client/session/QueueDeleteTest.java?rev=1716658&r1=1716657&r2=1716658&view=diff
==============================================================================
--- qpid/java/branches/6.0.x/systests/src/test/java/org/apache/qpid/client/session/QueueDeleteTest.java (original)
+++ qpid/java/branches/6.0.x/systests/src/test/java/org/apache/qpid/client/session/QueueDeleteTest.java Thu Nov 26 14:03:28 2015
@@ -106,5 +106,6 @@ public class QueueDeleteTest extends Qpi
Message message = consumer.receive(RECEIVE_TIMEOUT);
assertNotNull("Message not received", message);
_session.commit();
+ consumer.close();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org