1 files changed, 8 insertions, 2 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
index fe929b4965..f9c61d13e1 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
@@ -22,6 +22,7 @@ package org.apache.qpid.test.unit.message;
 
 import org.apache.qpid.test.utils.QpidBrokerTestCase;
 import org.apache.qpid.transport.Connection;
+import org.apache.qpid.transport.ConnectionSettings;
 import org.apache.qpid.transport.Session;
 
 import org.slf4j.Logger;
@@ -32,7 +33,6 @@ import javax.jms.*;
 import java.util.Properties;
 import java.io.*;
 
-
 /**
  * This test makes sure that utf8 characters can be used for
  * specifying exchange, queue name and routing key.
@@ -88,7 +88,13 @@ public class UTF8Test extends QpidBrokerTestCase
     private void declareQueue(String exch, String routkey, String qname) throws Exception
     {
         Connection conn = new Connection();
-        conn.connect("localhost", QpidBrokerTestCase.DEFAULT_PORT, "test", "guest", "guest",false);
+        ConnectionSettings settings = new ConnectionSettings();
+        settings.setUsername("guest");
+        settings.setPassword("guest");
+        settings.setHost(getBroker().getHost());
+        settings.setPort(getBroker().getPort());
+        settings.setProtocol(getBroker().getTransport());
+        conn.connect(settings);
         Session sess = conn.createSession(0);
         sess.exchangeDeclare(exch, "direct", null, null);
         sess.queueDeclare(qname, null, null);