You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2015/01/13 17:50:20 UTC
qpid-jms git commit: Close down the ActiveMQ connections used to
populate destinations.
Repository: qpid-jms
Updated Branches:
refs/heads/master bfb329a0c -> dbf4fe01e
Close down the ActiveMQ connections used to populate destinations.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/dbf4fe01
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/dbf4fe01
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/dbf4fe01
Branch: refs/heads/master
Commit: dbf4fe01efc43a2db98ffdd6958843dcceaa5a8c
Parents: bfb329a
Author: Timothy Bish <ta...@gmail.com>
Authored: Tue Jan 13 11:50:12 2015 -0500
Committer: Timothy Bish <ta...@gmail.com>
Committed: Tue Jan 13 11:50:12 2015 -0500
----------------------------------------------------------------------
.../test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/dbf4fe01/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
----------------------------------------------------------------------
diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
index 3580a89..522907c 100644
--- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
+++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
@@ -375,6 +375,7 @@ public class QpidJmsTestSupport {
Session amqSession = activemqConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue amqTestQueue = amqSession.createQueue(name.getMethodName());
sendMessages(activemqConnection, amqTestQueue, count);
+ activemqConnection.close();
}
protected void sendToAmqTopic(int count) throws Exception {
@@ -382,6 +383,7 @@ public class QpidJmsTestSupport {
Session amqSession = activemqConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic amqTestTopic = amqSession.createTopic(name.getMethodName());
sendMessages(activemqConnection, amqTestTopic, count);
+ activemqConnection.close();
}
protected BrokerPlugin configureAuthentication() throws Exception {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org