mqtt

Documentation

Index

• func Destroy(messageQueue *MessageQueue)
• type MessageQueue
  • func New(address string, userName string, password string) (*MessageQueue, error)
  • func (messageQueue *MessageQueue) Publish(topic string, event *data_protocol.CloudEvent) error
  • func (messageQueue *MessageQueue) Subscribe(group string, topic string, handler common.MessageHandler) error
  • func (messageQueue *MessageQueue) UnSubscribe(group string, topic string) error

Functions

func Destroy

func Destroy(messageQueue *MessageQueue)

Types

type MessageQueue

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

func New

func New(address string, userName string, password string) (*MessageQueue, error)

func (*MessageQueue) Publish

func (messageQueue *MessageQueue) Publish(topic string, event *data_protocol.CloudEvent) error

func (*MessageQueue) Subscribe

func (messageQueue *MessageQueue) Subscribe(group string, topic string, handler common.MessageHandler) error

func (*MessageQueue) UnSubscribe

func (messageQueue *MessageQueue) UnSubscribe(group string, topic string) error