From 019b6e4d4197cb8fdd4960b335ca526c6608b758 Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Mon, 5 May 2008 15:40:50 +0000
Subject: 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
---
 .../main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'java/client/src')

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>']*
-- 
cgit v1.2.1