mq

Documentation

Index

• type Message
  • func NewMessage(topic string, body []byte) *Message
• type MessageExt
• type SendResult
  • func NewSendResult(status int, msgID string) *SendResult

Types

type Message

type Message struct {
	Topic string
	Body  []byte
}

func NewMessage

func NewMessage(topic string, body []byte) *Message

type MessageExt

type MessageExt struct {
	MsgID string
	Message
}

type SendResult

type SendResult struct {
	Status int
	MsgID  string
}

func NewSendResult

func NewSendResult(status int, msgID string) *SendResult