Make MessageBufferU constructor public, close msgpack#210

So it can be used to unpack read-only ByteBuffers

Author: slandelle

msgpack-core/src/main/java/org/msgpack/core/buffer/MessageBufferU.java

@@ -12,7 +12,7 @@
  */
 public class MessageBufferU extends MessageBuffer {
 
- MessageBufferU(ByteBuffer bb) {
+ public MessageBufferU(ByteBuffer bb) {
  super(null, 0L, bb.capacity(), bb.order(ByteOrder.BIG_ENDIAN));
  checkNotNull(reference);
  }

msgpack-core/src/test/scala/org/msgpack/core/ByteStringTest.scala

@@ -0,0 +1,41 @@
+package org.msgpack.core
+
+import akka.util.ByteString
+import org.msgpack.core.buffer.{MessageBufferU, MessageBuffer, MessageBufferInput, ByteBufferInput}
+
+class ByteStringTest extends MessagePackSpec {
+
+ val unpackedString = "foo"
+ val byteString = ByteString(createMessagePackData(_.packString(unpackedString)))
+
+ "Regular ByteBufferInput" should {
+ "fail to read a ByteString's ByteBuffer" in {
+
+ val input = new ByteBufferInput(byteString.asByteBuffer)
+
+ a[RuntimeException] shouldBe thrownBy(new MessageUnpacker(input).unpackString())
+ }
+ }
+
+ "A MessageBufferU based ByteBufferInput" should {
+ "be able to read a ByteString's ByteBuffer" in {
+
+ val input = new MessageBufferInput {
+
+ private var isRead = false
+
+ override def next(): MessageBuffer =
+ if (isRead) {
+ null
+ } else {
+ isRead = true
+ new MessageBufferU(byteString.asByteBuffer)
+ }
+
+ override def close(): Unit = {}
+ }
+
+ new MessageUnpacker(input).unpackString() shouldBe unpackedString
+ }
+ }
+}

project/Build.scala

@@ -165,7 +165,8 @@ object Build extends Build {
  "org.xerial" % "xerial-core" % "3.3.5" % "test",
  "org.msgpack" % "msgpack" % "0.6.11" % "test",
  junitInterface,
- "commons-codec" % "commons-codec" % "1.10" % "test"
+ "commons-codec" % "commons-codec" % "1.10" % "test",
+ "com.typesafe.akka" %% "akka-actor"% "2.3.9"
  )
 
  val jacksonLib = Seq(