diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-05 13:39:45 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-10-05 13:39:45 +0000 |
| commit | 6f49a68956686a393430588b11c02fc2f6236511 (patch) | |
| tree | 9551f6f918851d8cedf5b5c447ac2ee83743cf11 /java/client | |
| parent | df4ee40ba5da93b711af91a66195343343d5b7be (diff) | |
| download | qpid-python-6f49a68956686a393430588b11c02fc2f6236511.tar.gz | |
Changed for removing buffer copy
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@582267 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 8 |
1 files changed, 2 insertions, 6 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 c612f34116..b4fdddce60 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 @@ -127,8 +127,7 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By public void onMessage(Message message) - { - boolean messageOk = false; + { int channelId = getSession().getChannelId(); long deliveryId = message.getMessageTransferId(); String consumerTag = getConsumerTag().toString(); @@ -139,10 +138,7 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By new UnprocessedMessage_0_10(channelId, deliveryId, consumerTag, exchange, routingKey, redelivered); try { - ByteBuffer buff = message.readData(); - ByteBuffer newBuf = ByteBuffer.allocate(buff.remaining()); - newBuf.put(buff); - newMessage.receiveBody(newBuf); + newMessage.receiveBody(message.readData()); } catch (IOException e) { |