1 files changed, 10 insertions, 0 deletions
diff --git a/java/client/test/src/org/apache/qpid/client/TestAMQSession.java b/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
index 78086706ec..5ec13c45cc 100644
--- a/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
+++ b/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
@@ -20,6 +20,7 @@ package org.apache.qpid.client;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.Assert;
+import org.junit.After;
 import org.apache.qpid.AMQException;
 import org.apache.qpid.client.transport.TransportConnection;
 import org.apache.qpid.client.vmbroker.AMQVMBrokerCreationException;
@@ -86,6 +87,15 @@ public class TestAMQSession {
         Assert.assertEquals("Queue names should match from QueueReceiver with selector",_queue.getQueueName(),receiver.getQueue().getQueueName());
     }
 
+    @After
+    public void stopVmBrokers()
+    {
+        TransportConnection.killVMBroker(1);
+        _queue = null;
+        _topic = null;
+        _session = null;
+    }
+
     public static junit.framework.Test suite()
     {
         return new JUnit4TestAdapter(TestAMQSession.class);