diff options
| author | Gordon Sim <gsim@apache.org> | 2008-05-05 15:40:50 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-05-05 15:40:50 +0000 |
| commit | 019b6e4d4197cb8fdd4960b335ca526c6608b758 (patch) | |
| tree | af36d05cc0cee9e7b8a2c0c60b839f7b7cb6c13f /java | |
| parent | ba2bb1241b4825169d6781e028cd2c9307aa2c79 (diff) | |
| download | qpid-python-019b6e4d4197cb8fdd4960b335ca526c6608b758.tar.gz | |
QPID-1008: allow for case where 0-10 message-properties are not included in a received message
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@653508 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java index 506860d2a1..fcc21428e9 100644 --- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java +++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java @@ -167,6 +167,9 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By AMQShortString routingKey; boolean redelivered = false; Struct[] headers = {message.getMessageProperties(), message.getDeliveryProperties()}; + if (headers[0] == null) { + headers[0] = new MessageProperties(); + } if( message.getDeliveryProperties() != null ) { exchange = new AMQShortString(message.getDeliveryProperties().getExchange()); @@ -190,7 +193,7 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By getSession().getAMQConnection().exceptionReceived(e); } // if there is a replyto destination then we need to request the exchange info - ReplyTo replyTo = message.getMessageProperties().getReplyTo(); + ReplyTo replyTo = ((MessageProperties) headers[0]).getReplyTo(); if (replyTo != null && replyTo.getExchange() != null && !replyTo.getExchange().equals("")) { // <exch_class>://<exch_name>/[<destination>]/[<queue>]?<option>='<value>'[,<option>='<value>']* |