We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c0d8d4f commit 46eea2fCopy full SHA for 46eea2f
src/main/java/com/github/brainlag/nsq/frames/MessageFrame.java
@@ -18,11 +18,12 @@ public void setData(byte[] bytes) {
18
timestamp = buf.readLong();
19
attempts = buf.readShort();
20
buf.readBytes(messageId);
21
- if (buf.hasArray()) {
22
- messageBody = buf.readBytes(buf.readableBytes()).array();
+ ByteBuf messageBodyBuf = buf.readBytes(buf.readableBytes());
+ if (messageBodyBuf.hasArray()) {
23
+ messageBody = messageBodyBuf.array();
24
} else {
- byte[] array = new byte[buf.readableBytes()];
25
- buf.readBytes(array);
+ byte[] array = new byte[messageBodyBuf.readableBytes()];
26
+ messageBodyBuf.readBytes(array);
27
messageBody = array;
28
}
29
0 commit comments