diff options
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java index 9185bc87e8..13568594d9 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java @@ -137,7 +137,14 @@ public class AMQQueue extends AMQDestination implements Queue public AMQShortString getRoutingKey() { - return getAMQQueueName(); + if( getDestinationName() != null && ! getDestinationName().equals("")) + { + return getDestinationName(); + } + else + { + return getAMQQueueName(); + } } public boolean isNameRequired() |