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