Fix consumer performance bottleneck (#198)

* Fix readUint8Array

The binary.Read method falls back to using the reflect package on
*[]uint8 data types, which is much slower.

This seems to fix the consumer performance on big messages (> 100B), but
not on small ones.

* Add message bytes test

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

---------

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>
Co-authored-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

Author: maharifu

pkg/stream/buffer_reader.go

@@ -59,6 +59,6 @@ func readString(readerStream io.Reader) string {
 
 func readUint8Array(readerStream io.Reader, size uint32) []uint8 {
 	var res = make([]uint8, size)
-	_ = binary.Read(readerStream, binary.BigEndian, &res)
+	_ = binary.Read(readerStream, binary.BigEndian, res)
 	return res
 }

pkg/stream/consumer_test.go

@@ -437,7 +437,7 @@ var _ = Describe("Streaming Consumers", func() {
 			}
 		}(chConfirm, producer)
 		Expect(err).NotTo(HaveOccurred())
-		msg := amqp.NewMessage([]byte("message"))
+		msg := amqp.NewMessage([]byte{0x00, 0x0e, 0x01, 0x0f, 0x05, 0x08, 0x04, 0x03})
 		msg.Properties = &amqp.MessageProperties{
 			MessageID:          nil,
 			UserID:             nil,
@@ -466,6 +466,7 @@ var _ = Describe("Streaming Consumers", func() {
 				Expect(message.Properties.To).To(Equal("ToTest"))
 				Expect(message.Properties.ContentType).To(Equal("ContentTypeTest"))
 				Expect(message.Properties.ContentEncoding).To(Equal("ContentEncodingTest"))
+				Expect(message.Data[0]).To(Equal([]byte{0x00, 0x0e, 0x01, 0x0f, 0x05, 0x08, 0x04, 0x03}))
 
 			}, NewConsumerOptions().SetOffset(OffsetSpecification{}.First()).SetConsumerName("consumer_test"))
 		Expect(err).NotTo(HaveOccurred())