message

Documentation

Index

• func ToPublish(msg *Message, version packet.Version) *packet.Publish
• type Message
  • func FromPublish(publish *packet.Publish) *Message
  • func (m *Message) Copy() *Message
  • func (m *Message) String() string
  • func (m *Message) TotalBytes(version packet.Version) uint32

Functions

func ToPublish

func ToPublish(msg *Message, version packet.Version) *packet.Publish

Types

type Message

type Message struct {
	Dup      bool
	QoS      uint8
	Retained bool
	Topic    string
	Payload  []byte
	PacketId packet.Id

	ContentType            string
	CorrelationData        []byte
	MessageExpiry          uint32
	PayloadFormat          packet.PayloadFormat
	ResponseTopic          string
	SubscriptionIdentifier []uint32
}

func FromPublish

func FromPublish(publish *packet.Publish) *Message

func (*Message) Copy

func (m *Message) Copy() *Message

func (*Message) String

func (m *Message) String() string

func (*Message) TotalBytes

func (m *Message) TotalBytes(version packet.Version) uint32

TotalBytes return the publish packets total bytes.