Fix bug, DirectByteBuffer dose not have a backed java array

apache · Mar 1, 2017 · eb1a5e7 · eb1a5e7
1 parent ff379f4
commit eb1a5e7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -1435,7 +1435,9 @@ public AppendMessageResult doAppend(final long fileFromOffset, final ByteBuffer
                 messagesByteBuff.position(msgPos + msgLen);
             }
 
-            byteBuffer.put(messagesByteBuff.array(), 0, totalMsgLen);
+            messagesByteBuff.position(0);
+            messagesByteBuff.limit(totalMsgLen);
+            byteBuffer.put(messagesByteBuff);
             messageExtBatch.setEncodedBuff(null);
             AppendMessageResult result = new AppendMessageResult(AppendMessageStatus.PUT_OK, wroteOffset, totalMsgLen, msgIdBuilder.toString(),
                 messageExtBatch.getStoreTimestamp(), beginQueueOffset, CommitLog.this.defaultMessageStore.now() - beginTimeMills);