Author: arnaudsimon
Date: Tue Oct  2 07:18:46 2007
New Revision: 581256

URL: http://svn.apache.org/viewvc?rev=581256&view=rev
Log:
Changed to use QpidTestCase

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/InvalidDestinationTest.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/InvalidDestinationTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/InvalidDestinationTest.java?rev=581256&r1=581255&r2=581256&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/InvalidDestinationTest.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/InvalidDestinationTest.java
 Tue Oct  2 07:18:46 2007
@@ -22,15 +22,9 @@
 package org.apache.qpid.test.unit.basic;
 
 import org.apache.qpid.client.AMQConnection;
-import org.apache.qpid.client.AMQDestination;
-import org.apache.qpid.client.AMQSession;
 import org.apache.qpid.client.AMQQueue;
-import org.apache.qpid.client.vmbroker.AMQVMBrokerCreationException;
-import org.apache.qpid.client.transport.TransportConnection;
+import org.apache.qpid.testutil.QpidTestCase;
 
-import junit.framework.TestCase;
-
-import javax.jms.MessageConsumer;
 import javax.jms.Session;
 import javax.jms.QueueSession;
 import javax.jms.Queue;
@@ -38,39 +32,18 @@
 import javax.jms.TextMessage;
 import javax.jms.InvalidDestinationException;
 
-public class InvalidDestinationTest extends TestCase
+public class InvalidDestinationTest extends QpidTestCase
 {
     private AMQConnection _connection;
-    private AMQDestination _destination;
-    private AMQSession _session;
-    private MessageConsumer _consumer;
-
-    private static final String VM_BROKER = "vm://:1";
-
 
     protected void setUp() throws Exception
     {
         super.setUp();
-        createVMBroker();
-        _connection = new AMQConnection(VM_BROKER, "guest", "guest", 
"ReceiveTestClient", "test");
-    }
-
-    public void createVMBroker()
-    {
-        try
-        {
-            TransportConnection.createVMBroker(1);
-        }
-        catch (AMQVMBrokerCreationException e)
-        {
-            fail("Unable to create broker: " + e);
-        }
+        _connection = (AMQConnection) getConnection("guest", "guest");
     }
 
     protected void tearDown() throws Exception
     {
-        _connection.close();
-        TransportConnection.killVMBroker(1);
         super.tearDown();
     }
 
@@ -83,7 +56,7 @@
         QueueSession queueSession = _connection.createQueueSession(false, 
Session.AUTO_ACKNOWLEDGE);
 
         // This is the only easy way to create and bind a queue from the API 
:-(
-        MessageConsumer consumer = 
queueSession.createConsumer(validDestination);
+        queueSession.createConsumer(validDestination);
 
         QueueSender sender = queueSession.createSender(invalidDestination);
         TextMessage msg = queueSession.createTextMessage("Hello");


Reply via email to