Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

close connection required in some tests before the broker is re-started

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515940 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-03-08 06:29:04 +00:00
parent fa2d43f379
commit 825447a615
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java
View File

@ -152,7 +152,7 @@ public class RecoveryBrokerTest extends BrokerRestartTestSupport {
connection1.send(createMessage(producerInfo1, destination, DeliveryMode.PERSISTENT)); connection1.send(createMessage(producerInfo1, destination, DeliveryMode.PERSISTENT));
connection1.send(createMessage(producerInfo1, destination, DeliveryMode.PERSISTENT)); connection1.send(createMessage(producerInfo1, destination, DeliveryMode.PERSISTENT));
connection1.send(createMessage(producerInfo1, destination, DeliveryMode.PERSISTENT)); connection1.send(createMessage(producerInfo1, destination, DeliveryMode.PERSISTENT));
connection1.request(closeConnectionInfo(connectionInfo1));
// Restart the broker. // Restart the broker.
restartBroker(); restartBroker();
@ -193,6 +193,7 @@ public class RecoveryBrokerTest extends BrokerRestartTestSupport {
Message message = createMessage(producerInfo, destination); Message message = createMessage(producerInfo, destination);
message.setPersistent(true); message.setPersistent(true);
connection.send(message); connection.send(message);
connection.request(closeConnectionInfo(connectionInfo));
// restart the broker. // restart the broker.
restartBroker(); restartBroker();
@ -270,7 +271,7 @@ public class RecoveryBrokerTest extends BrokerRestartTestSupport {
// Commit // Commit
connection.send(createCommitTransaction1Phase(connectionInfo, txid)); connection.send(createCommitTransaction1Phase(connectionInfo, txid));
connection.request(closeConnectionInfo(connectionInfo));
// restart the broker. // restart the broker.
restartBroker(); restartBroker();
@ -326,7 +327,7 @@ public class RecoveryBrokerTest extends BrokerRestartTestSupport {
} }
// Commit // Commit
connection.send(createCommitTransaction1Phase(connectionInfo, txid)); connection.send(createCommitTransaction1Phase(connectionInfo, txid));
connection.request(closeConnectionInfo(connectionInfo));
// restart the broker. // restart the broker.
restartBroker(); restartBroker();