diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java
index 5330fe09d5..12b2818272 100755
--- a/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java
@@ -73,6 +73,7 @@ public class XARecoveryBrokerTest extends BrokerRestartTestSupport {
 
         // Since prepared but not committed.. they should not get delivered.
         assertNoMessagesLeft(connection);
+        connection.request(closeConnectionInfo(connectionInfo));
 
         // restart the broker.
         restartBroker();
@@ -134,7 +135,7 @@ public class XARecoveryBrokerTest extends BrokerRestartTestSupport {
         
         // Commit
         connection.send(createCommitTransaction1Phase(connectionInfo, txid));
-
+        connection.request(closeConnectionInfo(connectionInfo));
         // restart the broker.
         restartBroker();