From 6f3915b6916ae8ee0ba07b27defdea00a07ae664 Mon Sep 17 00:00:00 2001 From: Andrew Donald Kennedy Date: Thu, 3 Mar 2011 01:57:57 +0000 Subject: QPID-3066: Make UTF8 test use 0-10 connection settings git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/grkvlt-network-20110301@1076496 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/test/unit/message/UTF8Test.java | 10 ++++++++-- 1 file 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); -- cgit v1.2.1