Author: marnie
Date: Tue Nov 7 01:12:52 2006
New Revision: 472042
URL: http://svn.apache.org/viewvc?view=rev&rev=472042
Log:
Added cleanup of invm broker
Modified:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
Modified:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java?view=diff&rev=472042&r1=472041&r2=472042
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
Tue Nov 7 01:12:52 2006
@@ -20,6 +20,7 @@
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;
@@ -84,6 +85,15 @@
receiver = _session.createReceiver(_queue, "abc");
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()
