summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-02-12 23:52:01 +0000
committerRafael H. Schloming <rhs@apache.org>2008-02-12 23:52:01 +0000
commiteee5501a55c9fe6386df9f43739cebf6cd6f9356 (patch)
treec24b20127138ea103480a0efbc59db359af309e9
parenta97688f2d3e2e5fb73b643f186660c0676923db3 (diff)
downloadqpid-python-eee5501a55c9fe6386df9f43739cebf6cd6f9356.tar.gz
applied patch from rajith to fix reply-to
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627187 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/AMQDestination.java8
1 files changed, 8 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java b/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
index 6c7575429a..0e36a09bbd 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java
@@ -231,6 +231,14 @@ public abstract class AMQDestination implements Destination, Referenceable
sb.append('?');
+ if (_routingKey != null)
+ {
+ sb.append(BindingURL.OPTION_ROUTING_KEY);
+ sb.append("='");
+ sb.append(_routingKey).append("'");
+ sb.append(URLHelper.DEFAULT_OPTION_SEPERATOR);
+ }
+
if (_isDurable)
{
sb.append(BindingURL.OPTION_DURABLE);