diff options
Diffstat (limited to 'java/common')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java b/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java index 1774fa1194..529a05b2e2 100644 --- a/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java +++ b/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java @@ -259,7 +259,14 @@ public class AMQBindingURL implements BindingURL { if (_exchangeClass.equals(ExchangeDefaults.DIRECT_EXCHANGE_CLASS)) { - return getQueueName(); + if (containsOption(BindingURL.OPTION_ROUTING_KEY)) + { + return new AMQShortString(getOption(OPTION_ROUTING_KEY)); + } + else + { + return getQueueName(); + } } if (containsOption(BindingURL.OPTION_ROUTING_KEY)) |