You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2010/04/29 19:59:34 UTC
svn commit: r939405 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java
Author: rajith
Date: Thu Apr 29 17:59:34 2010
New Revision: 939405
URL: http://svn.apache.org/viewvc?rev=939405&view=rev
Log:
Modified the toString() to include the options.
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java?rev=939405&r1=939404&r2=939405&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java Thu Apr 29 17:59:34 2010
@@ -275,6 +275,15 @@ public class AMQConnectionURL implements
sb.append(URLHelper.printOptions(_failoverOptions));
sb.append("'");
}
+
+ for (String key : _options.keySet())
+ {
+ if (!key.equals(OPTIONS_FAILOVER) || !key.equals(OPTIONS_BROKERLIST))
+ {
+ sb.append(URLHelper.DEFAULT_OPTION_SEPERATOR).append(key).append("='");
+ sb.append(_options.get(key)).append("'");
+ }
+ }
return sb.toString();
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org