From ad0910c4f2c7ef5bee8305d5cad76ecf8cf926fb Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Wed, 16 Jan 2008 21:57:47 +0000 Subject: Please refer JIRA's 739,740 and 741 for more information about the issues. AMQDestination Renamed the destinationName to routingKey as it is incorrectly used. Also modified it to recognize fannout exchange AMQQueue Modified to return the proper routing key to support situations where the queue name and the routing key is different. BasicMessageProducer_0_10.java Added a temp hack to interoperate with python. The bug is in python and it needs to be fixed. Basically python relies on the content length to pass the content frames properly. So I added a line to calculate the content length and sets it in the message properties. The rest was modified to reflect the change done in AMQDestination. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612581 13f79535-47bb-0310-9956-ffa450edef68 --- java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) (limited to 'java/common') 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)) -- cgit v1.2.1