diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2007-01-12 08:52:31 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2007-01-12 08:52:31 +0000 |
| commit | c80441a3500dc1f38f99d11d3ee50ed0ad20b13c (patch) | |
| tree | af12dc016f67c823b3d15c83f38aea9363957a7b /java/client/src/main | |
| parent | 8ad8a118a88802c6fe9421c0fcbdf70abf76ae5f (diff) | |
| download | qpid-python-c80441a3500dc1f38f99d11d3ee50ed0ad20b13c.tar.gz | |
QPID-282
Updated AMQConnection and AMQBrokerDetails to check the host:port and add tcp:// if there is no protocol specified.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@495517 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/main')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java | 11 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 2 |
2 files changed, 12 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java b/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java index e59b6fbe19..8fb87f9e64 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java @@ -334,4 +334,15 @@ public class AMQBrokerDetails implements BrokerDetails } + public static String checkTransport(String broker) + { + if ((!broker.contains("://"))) + { + return "tcp://" + broker; + } + else + { + return broker; + } + } } diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index ca101cb3b5..b82a735f06 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java @@ -148,7 +148,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect this(new AMQConnectionURL(ConnectionURL.AMQ_PROTOCOL + "://" + username + ":" + password + "@" + (clientName==null?"":clientName) + - virtualHost + "?brokerlist='" + broker + "'")); + virtualHost + "?brokerlist='" + AMQBrokerDetails.checkTransport(broker) + "'")); } public AMQConnection(String host, int port, String username, String password, |