fixed bugs; does handle msgpack message stream