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);