From c97b97ed885b236b6abb83d0be113ffdc2620090 Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Thu, 8 Mar 2007 10:59:29 +0000
Subject: [PATCH] close connection before restarting the broker

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516008 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/org/apache/activemq/broker/XARecoveryBrokerTest.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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();