Author: grkvlt
Date: Thu Mar 3 01:57:57 2011
New Revision: 1076496
URL: http://svn.apache.org/viewvc?rev=1076496&view=rev
Log:
QPID-3066: Make UTF8 test use 0-10 connection settings
Modified:
qpid/branches/grkvlt-network-20110301/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
Modified:
qpid/branches/grkvlt-network-20110301/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
URL:
http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20110301/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java?rev=1076496&r1=1076495&r2=1076496&view=diff
==============================================================================
---
qpid/branches/grkvlt-network-20110301/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
(original)
+++
qpid/branches/grkvlt-network-20110301/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/message/UTF8Test.java
Thu Mar 3 01:57:57 2011
@@ -22,6 +22,7 @@ package org.apache.qpid.test.unit.messag
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 QpidBroker
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);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
