message

type JsonMessage struct {
	// contains filtered or unexported fields
}

type Message interface {
	ID() []byte
	SetID(id []byte) error

	// Used for recording extra data, e.g, retry count
	Metadata() map[string]interface{}
	SetMetadata(metadata map[string]interface{}) error

	Data() []byte
	SetData(data []byte) error

	// Converts the message into a binary package
	Pack() ([]byte, error)

	// Converts a binary package into the message
	Unpack([]byte) error

	String() string
}

type MessageIDGenerator func() ([]byte, error)