nsq

Nov 6, 2023

Changes in this version

+ func NewConsumer(h Consumer, m Marshaller) nsq.Handler

+ type Consumer interface

+ Consume func(ctx context.Context, message *Message) error

+ type Headers map[string]string

+ type Marshaller marshaller.Marshaller

+ func NewMsgPackMarshaller() Marshaller

+ type Message struct

+ Body []byte

+ Headers Headers

+ func NewMessage(body []byte) *Message

+ type Producer interface

+ Produce func(ctx context.Context, topic string, message *Message) error