diff options
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java | 2 |
1 files changed, 1 insertions, 1 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 94b835dd1a..807a7a14e5 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 @@ -249,7 +249,7 @@ public class AMQMessageDelegate_0_10 extends AbstractAMQMessageDelegate { ReplyTo replyTo = _messageProps.getReplyTo(); - if (replyTo == null) + if ((replyTo == null) || ((replyTo.getExchange() == null) && (replyTo.getRoutingKey() == null))) { return null; } |