message

Dec 12, 2022

Changes in this version

+ type StreamMessage interface

+ GetAMQPValue func() interface{}

+ GetApplicationProperties func() map[string]interface{}

+ GetData func() [][]byte

+ GetMessageAnnotations func() amqp.Annotations

+ GetMessageHeader func() *amqp.MessageHeader

+ GetMessageProperties func() *amqp.MessageProperties

+ GetPublishingId func() int64

+ HasPublishingId func() bool

+ MarshalBinary func() ([]byte, error)

+ SetPublishingId func(id int64)

+ UnmarshalBinary func(data []byte) error