fixed issue with transactions

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

1 files changed, 2 insertions, 4 deletions

diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java
index 1a86975b96..f60d944b42 100644
--- a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java
+++ b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/TransactedTest.java
@@ -27,8 +27,6 @@ import org.apache.qpid.client.AMQSession;
 import org.apache.qpid.framing.AMQShortString;
 import org.apache.qpid.jms.Session;
 import org.apache.qpid.testutil.QpidTestCase;
-import org.apache.qpid.AMQException;
-import org.apache.qpid.url.URLSyntaxException;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -247,13 +245,13 @@ public class TransactedTest extends QpidTestCase
     {
         try
         {
-            AMQConnection con = new AMQConnection("vm://:1", "guest", "guest", "consumer1", "test");
+            AMQConnection con = (AMQConnection) getConnection("guest", "guest");
 
             Session consumerSession = con.createSession(true, Session.SESSION_TRANSACTED);
             AMQQueue queue3 = new AMQQueue(consumerSession.getDefaultQueueExchangeName(), new AMQShortString("Q3"), false);
             MessageConsumer consumer = consumerSession.createConsumer(queue3);
 
-            AMQConnection con2 = new AMQConnection("vm://:1", "guest", "guest", "producer1", "test");
+            AMQConnection con2 = (AMQConnection) getConnection("guest", "guest");
             Session producerSession = con2.createSession(true, Session.SESSION_TRANSACTED);
             MessageProducer producer = producerSession.createProducer(queue3);