diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2010-11-24 19:28:55 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2010-11-24 19:28:55 +0000 |
| commit | 599ca0ca8256e8c75604a334b79838e438a5bae1 (patch) | |
| tree | 7398eed820bbd5b47b76b41ff7c61607e6eb047a | |
| parent | a5bab5c983cd1a14b347d272fc207c2c6963c941 (diff) | |
| download | qpid-python-599ca0ca8256e8c75604a334b79838e438a5bae1.tar.gz | |
QPID-2959
If the exchange or routing key is null, it's now being set to empty string.
If set to empty string the message will be sent to the nameless exchange.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1038773 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java index 08dd256512..522782a6cf 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java @@ -222,8 +222,10 @@ public class AMQMessageDelegate_0_10 extends AbstractAMQMessageDelegate String exchange = replyTo.getExchange(); String routingKey = replyTo.getRoutingKey(); - dest = generateDestination(exchange == null ? null : new AMQShortString(exchange), - routingKey == null ? null : new AMQShortString(routingKey)); + dest = generateDestination(exchange == null ? new AMQShortString("") : + new AMQShortString(exchange), + routingKey == null ? new AMQShortString(""): + new AMQShortString(routingKey)); |