Parse ByteBufs correctly if no array is available.

Author: dpapworth-qc

src/main/java/com/github/brainlag/nsq/frames/MessageFrame.java

@@ -18,7 +18,13 @@ public void setData(byte[] bytes) {
 		timestamp = buf.readLong();
 		attempts = buf.readShort();
 		buf.readBytes(messageId);
-		messageBody = buf.readBytes(buf.readableBytes()).array();
+		if (buf.hasArray()) {
+			messageBody = buf.readBytes(buf.readableBytes()).array();
+		} else {
+			byte[] array = new byte[buf.readableBytes()];
+			buf.readBytes(array);
+			messageBody = array;
+		}
 	}
 
 	public long getTimestamp() {

src/main/java/com/github/brainlag/nsq/netty/NSQDecoder.java

@@ -26,7 +26,13 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) t
 		}
 		frame.setSize(size);
 		ByteBuf bytes = in.readBytes(frame.getSize() - 4); //subtract 4 because the frame id is included
-		frame.setData(bytes.array());
+		if (bytes.hasArray()) {
+			frame.setData(bytes.array());
+		} else {
+			byte[] array = new byte[bytes.readableBytes()];
+			bytes.readBytes(array);
+			frame.setData(array);
+		}
 		out.add(frame);
 	}