message

Documentation

Index

• func Marshal(message *Message) ([]byte, error)
• func Unmarshal(data []byte, message *Message) error
• type Headers
• type Message
  • func New(body []byte) *Message

Functions

func Marshal

func Marshal(message *Message) ([]byte, error)

Marshal a message.

func Unmarshal

func Unmarshal(data []byte, message *Message) error

Unmarshal a message.

Types

type Headers

type Headers map[string]string

Headers of message.

type Message

type Message struct {
	Headers Headers `msgpack:"headers"`
	Body    []byte  `msgpack:"body"`

	*nsq.Message `msgpack:"-"`
}

Message for NSQ.

func New

func New(body []byte) *Message

New message.