summaryrefslogtreecommitdiff
path: root/java/client/src/main
diff options
context:
space:
mode:
authorAndrew Donald Kennedy <grkvlt@apache.org>2010-07-26 09:28:42 +0000
committerAndrew Donald Kennedy <grkvlt@apache.org>2010-07-26 09:28:42 +0000
commitba9645e53311a789c3c48423570896d816cc0648 (patch)
tree4e007b7f3ccf2c789fe382d036a2f7f7225a1c1c /java/client/src/main
parent64e3d09793dbd46e03cb9673c76c9ef36e9b5f22 (diff)
downloadqpid-python-ba9645e53311a789c3c48423570896d816cc0648.tar.gz
QPID-2697: Print AMQConnectionURL options
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@979212 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/main')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java18
1 files changed, 13 insertions, 5 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java
index 65208722d7..93b4c51a8f 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java
@@ -254,14 +254,22 @@ public class AMQConnectionURL implements ConnectionURL
private String optionsToString()
{
- StringBuffer sb = new StringBuffer();
-
- sb.append("?" + OPTIONS_BROKERLIST + "='");
-
+ StringBuffer sb = new StringBuffer("?");
+
+ if (!_options.isEmpty())
+ {
+ for (Map.Entry<String, String> option : _options.entrySet())
+ {
+ sb.append(option.getKey()).append("='").append(option.getValue()).append("'");
+ sb.append(URLHelper.DEFAULT_OPTION_SEPERATOR);
+ }
+ }
+
+ sb.append(OPTIONS_BROKERLIST).append("='");
for (BrokerDetails service : _brokers)
{
sb.append(service.toString());
- sb.append(';');
+ sb.append(URLHelper.BROKER_SEPARATOR);
}
sb.deleteCharAt(sb.length() - 1);