From 7f82bedf5d7cc98a75b1a087d0e2e3e2555218c2 Mon Sep 17 00:00:00 2001
From: Arnaud Simon <arnaudsimon@apache.org>
Date: Mon, 1 Oct 2007 11:09:32 +0000
Subject: Changed onMessage to copy the incoming byteBuffer

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

(limited to 'qpid/java')

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 2f079446e4..9e0fb54d0f 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
@@ -29,10 +29,7 @@ import org.apache.qpid.framing.AMQShortString;
 import org.apache.qpid.AMQException;
 import org.apache.qpid.protocol.AMQConstant;
 import org.apache.qpidity.api.Message;
-import org.apache.qpidity.transport.Struct;
-import org.apache.qpidity.transport.ExchangeQueryResult;
-import org.apache.qpidity.transport.Future;
-import org.apache.qpidity.transport.RangeSet;
+import org.apache.qpidity.transport.*;
 import org.apache.qpidity.QpidException;
 import org.apache.qpidity.filter.MessageFilter;
 import org.apache.qpidity.filter.JMSSelectorFilter;
@@ -141,7 +138,10 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By
                 new UnprocessedMessage_0_10(channelId, deliveryId, consumerTag, exchange, routingKey, redelivered);
         try
         {
-            newMessage.receiveBody(message.readData());
+            ByteBuffer buff = message.readData();
+            ByteBuffer newBuf = ByteBuffer.allocate(buff.remaining()) ;
+            newBuf.put(buff);
+            newMessage.receiveBody(newBuf);
         }
         catch (IOException e)
         {
-- 
cgit v1.2.1