diff options
author | Andrew Donald Kennedy <grkvlt@apache.org> | 2011-03-03 01:57:57 +0000 |
---|---|---|
committer | Andrew Donald Kennedy <grkvlt@apache.org> | 2011-03-03 01:57:57 +0000 |
commit | 6f3915b6916ae8ee0ba07b27defdea00a07ae664 (patch) | |
tree | 9cab5b6d7d19a046f0740e1dbeea3a1719e07cee | |
parent | 18c2633dc7be62d86e6fee7bb901169266573c99 (diff) | |
download | qpid-python-6f3915b6916ae8ee0ba07b27defdea00a07ae664.tar.gz |
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
-rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java | 10 |
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); |