You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2007/01/23 21:59:55 UTC
svn commit: r499134 -
/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
Author: rhs
Date: Tue Jan 23 12:59:54 2007
New Revision: 499134
URL: http://svn.apache.org/viewvc?view=rev&rev=499134
Log:
added missing ByteBuffer.duplicate()
Modified:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
Modified: incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java?view=diff&rev=499134&r1=499133&r2=499134
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java (original)
+++ incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java Tue Jan 23 12:59:54 2007
@@ -281,7 +281,7 @@
mtb.destination = destination;
ByteBuffer buf = ByteBuffer.allocate((int)msg.getBodySize());
for (ByteBuffer bb : msg.getContents()) {
- buf.put(bb);
+ buf.put(bb.duplicate());
}
buf.flip();
mtb.body = new Content(Content.TypeEnum.INLINE_T, buf);