From 3f38a66203df93d676c4da0bff6fd2879cccbe5f Mon Sep 17 00:00:00 2001
From: Arnaud Simon <arnaudsimon@apache.org>
Date: Thu, 17 Jan 2008 14:06:17 +0000
Subject: see qpid-743

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@612821 13f79535-47bb-0310-9956-ffa450edef68
---
 .../qpid/client/BasicMessageConsumer_0_10.java       | 20 ++++++++++++++++----
 1 file changed, 16 insertions(+), 4 deletions(-)

(limited to 'qpid/java/client/src')

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
index e1a3d15a78..80b63c75c8 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
@@ -169,9 +169,22 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By
         int channelId = getSession().getChannelId();
         long deliveryId = message.getMessageTransferId();
         String consumerTag = getConsumerTag().toString();
-        AMQShortString exchange = new AMQShortString(message.getDeliveryProperties().getExchange());
-        AMQShortString routingKey = new AMQShortString(message.getDeliveryProperties().getRoutingKey());
-        boolean redelivered = message.getDeliveryProperties().getRedelivered();
+        AMQShortString exchange;
+        AMQShortString routingKey;
+        boolean redelivered = false;
+        Struct[] headers = {message.getMessageProperties(), message.getDeliveryProperties()};
+        if( message.getDeliveryProperties() != null )
+        {
+            exchange = new AMQShortString(message.getDeliveryProperties().getExchange());
+            routingKey = new AMQShortString(message.getDeliveryProperties().getRoutingKey());
+            redelivered = message.getDeliveryProperties().getRedelivered();
+        }
+        else
+        {
+            exchange = new AMQShortString("");
+            routingKey = new AMQShortString("");
+            headers[1] = new DeliveryProperties();
+        }
         UnprocessedMessage_0_10 newMessage =
                 new UnprocessedMessage_0_10(channelId, deliveryId, consumerTag, exchange, routingKey, redelivered);
         try
@@ -182,7 +195,6 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By
         {
             getSession().getAMQConnection().exceptionReceived(e);
         }
-        Struct[] headers = {message.getMessageProperties(), message.getDeliveryProperties()};
         // if there is a replyto destination then we need to request the exchange info
         ReplyTo replyTo = message.getMessageProperties().getReplyTo();
         if (replyTo != null && replyTo.getExchangeName() != null && !replyTo.getExchangeName().equals(""))
-- 
cgit v1.2.1