diff options
| author | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-07-26 09:28:42 +0000 |
|---|---|---|
| committer | Andrew Donald Kennedy <grkvlt@apache.org> | 2010-07-26 09:28:42 +0000 |
| commit | 001bf3f0bf4407d73807bf93259ea53efb631bea (patch) | |
| tree | a0f46247bd72471e27d93fa02657f24bb6a2be1c /qpid/java/client | |
| parent | b786059d21d5378b9f6eea1dc4158f3f4edf2db6 (diff) | |
| download | qpid-python-001bf3f0bf4407d73807bf93259ea53efb631bea.tar.gz | |
QPID-2697: Print AMQConnectionURL options
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@979212 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
2 files changed, 25 insertions, 5 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java index 65208722d7..93b4c51a8f 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java +++ b/qpid/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); diff --git a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java index 7400b524fd..2be3720c20 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java @@ -536,6 +536,18 @@ public class ConnectionURLTest extends TestCase assertTrue(connectionurl.getOption("timeout").equals("200")); assertTrue(connectionurl.getOption("immediatedelivery").equals("true")); } + + /** + * Test that options other than failover and brokerlist are returned in the string representation. + * <p> + * QPID-2697 + */ + public void testOptionToString() throws Exception + { + ConnectionURL url = new AMQConnectionURL("amqp://user:pass@temp/test?maxprefetch='12345'&brokerlist='tcp://localhost:5672'"); + + assertTrue("String representation should contain options and values", url.toString().contains("maxprefetch='12345'")); + } public static junit.framework.Test suite() { |