From d1946e3d0562e2d5d69153efd69e285af9138241 Mon Sep 17 00:00:00 2001 From: Arnaud Simon Date: Wed, 10 Oct 2007 14:37:37 +0000 Subject: Changed for using QpidTestCase git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@583495 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/client/ResetMessageListenerTest.java | 22 +++++++--------------- 1 file changed, 7 insertions(+), 15 deletions(-) (limited to 'java/client/src/test') diff --git a/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java b/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java index 5f7ca69554..5da9413c93 100644 --- a/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java +++ b/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java @@ -24,6 +24,7 @@ import junit.framework.TestCase; import org.apache.qpid.client.transport.TransportConnection; import org.apache.qpid.jndi.PropertiesFileInitialContextFactory; +import org.apache.qpid.testutil.QpidTestCase; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -53,7 +54,7 @@ import java.util.concurrent.TimeUnit; * the message listener later the _synchronousQueue is just poll()'ed and the first message delivered the remaining * messages will be left on the queue and lost, subsequent messages on the session will arrive first. */ -public class ResetMessageListenerTest extends TestCase +public class ResetMessageListenerTest extends QpidTestCase { private static final Logger _logger = LoggerFactory.getLogger(ResetMessageListenerTest.class); @@ -75,33 +76,25 @@ public class ResetMessageListenerTest extends TestCase protected void setUp() throws Exception { super.setUp(); - TransportConnection.createVMBroker(1); System.setProperty(AMQSession.IMMEDIATE_PREFETCH, "true"); - InitialContextFactory factory = new PropertiesFileInitialContextFactory(); - - Hashtable env = new Hashtable(); - - env.put("connectionfactory.connection", "amqp://guest:guest@MLT_ID/test?brokerlist='vm://:1'"); - env.put("queue.queue", "direct://amq.direct//ResetMessageListenerTest"); - - _context = factory.getInitialContext(env); - - Queue queue = (Queue) _context.lookup("queue"); + _clientConnection = getConnection("guest", "guest"); // Create Client 1 - _clientConnection = ((ConnectionFactory) _context.lookup("connection")).createConnection(); _clientSession = _clientConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Queue queue =_clientSession.createQueue("queue"); + _consumer1 = _clientSession.createConsumer(queue); + // Create Client 2 on same session _consumer2 = _clientSession.createConsumer(queue); // Create Producer - _producerConnection = ((ConnectionFactory) _context.lookup("connection")).createConnection(); + _producerConnection = getConnection("guest", "guest"); _producerConnection.start(); @@ -128,7 +121,6 @@ public class ResetMessageListenerTest extends TestCase _producerConnection.close(); super.tearDown(); - TransportConnection.killAllVMBrokers(); } public void testAsynchronousRecieve() -- cgit v1.2.1