svn commit: r516039 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java

[ra...@apache.org]

Author: rajdavies
Date: Thu Mar  8 05:28:59 2007
New Revision: 516039

URL: http://svn.apache.org/viewvc?view=rev&rev=516039
Log:
use request() instead of send()

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java?view=diff&rev=516039&r1=516038&r2=516039
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java Thu Mar  8 05:28:59 2007
@@ -347,7 +347,7 @@
         // Ack the last message.
         connection1.send(createAck(consumerInfo1, m, 2, MessageAck.STANDARD_ACK_TYPE));
         // Close the connection.
-        connection1.send(closeConnectionInfo(connectionInfo1));
+        connection1.request(closeConnectionInfo(connectionInfo1));
         connection1.stop();
         
         // Setup a second connection 
@@ -1293,7 +1293,7 @@
 
         ConsumerInfo consumerInfo1 = createConsumerInfo(sessionInfo1, destination);
         consumerInfo1.setPrefetchSize(1);
-        connection1.send(consumerInfo1);
+        connection1.request(consumerInfo1);
         
         // Send the messages
         connection1.send(createMessage(producerInfo, destination, deliveryMode));
@@ -1310,7 +1310,7 @@
         consumerInfo2.setBrowser(true);
         connection2.send(connectionInfo2);
         connection2.send(sessionInfo2);
-        connection2.send(consumerInfo2);
+        connection2.request(consumerInfo2);
 
         for( int i=0; i < 4; i++ ) {
             Message m1 = receiveMessage(connection1);