Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use request() instead of send() 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516039 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-03-08 13:28:59 +00:00
parent e39a679d2f
commit eeafa1cfef
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
View File

@ -347,7 +347,7 @@ public class BrokerTest extends BrokerTestSupport {
// 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 @@ public class BrokerTest extends BrokerTestSupport {
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 @@ public class BrokerTest extends BrokerTestSupport {
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);