You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ma...@apache.org on 2006/11/07 10:12:53 UTC
svn commit: r472042 -
/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/TestAMQSession.java
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()