1 files changed, 2 insertions, 0 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
index 5107b90f4f..d226c0785a 100755
--- a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
@@ -1503,11 +1503,13 @@ public class QpidBrokerTestCase extends QpidTestCase
         Destination destination = session.createQueue(getTestQueueName());
         MessageConsumer consumer = session.createConsumer(destination);
         sendMessage(session, destination, 1);
+        session.commit();
         connection.start();
         Message m1 = consumer.receive(RECEIVE_TIMEOUT);
         assertNotNull("Message 1 is not received", m1);
         assertEquals("Unexpected first message received", 0, m1.getIntProperty(INDEX));
         session.commit();
+        session.close();
     }
 
 }