@Override
            protected Input begin(Pipe.Schema<?> pipeSchema) throws IOException
            {
                return msgpackInput;
            }
Creates a msgpack pipe from a {@link MessageUnpacker}.
protostuff-msgpack/src/main/java/io/protostuff/MsgpackIOUtil.java