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 <[email protected]> Authored: Tue Jan 13 11:50:12 2015 -0500 Committer: Timothy Bish <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
