From 1d846a9e61d44c8806366e37bc68f5de7e21f855 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Thu, 8 Mar 2007 14:53:40 +0000 Subject: [PATCH] ensure connections are closed (so all messages are fludshed to the broker) before testing message delivery git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516063 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java index 4c3d1680d3..4c0398751f 100755 --- a/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java @@ -163,7 +163,7 @@ public class AdvisoryBrokerTest extends BrokerTestSupport { assertEquals(((ConsumerInfo)m1.getDataStructure()).getConsumerId(), consumerInfo2.getConsumerId()); // Close the second connection. - connection2.send(closeConnectionInfo(connectionInfo2)); + connection2.request(closeConnectionInfo(connectionInfo2)); connection2.stop(); // We should get an advisory of the consumer closing