Added cleanup of invm broker

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@472042 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 10 insertions, 0 deletions

diff --git a/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java b/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
index 78086706ec..5ec13c45cc 100644
--- a/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
+++ b/qpid/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);