diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2008-01-16 14:42:58 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2008-01-16 14:42:58 +0000 |
| commit | fff2f90e1970fe5dc30a78ce5ef2ce74d328e1f1 (patch) | |
| tree | 0bfd6531a0ea1e7e37b3ae35b76fe8f9509a213a /qpid/java | |
| parent | 051adb4365e077a5b0b0acee608493e59fc98c1f (diff) | |
| download | qpid-python-fff2f90e1970fe5dc30a78ce5ef2ce74d328e1f1.tar.gz | |
see QPID-739
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@612471 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -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() |