rocketmq

Documentation

Index

• Constants
• func InitRocketMQ(newObservers ...MQMessageObserver)
• func ShutdownNotifyConsumer()
• type MQMessageObserver
• type MQNotifyMessage
  • func (notify *MQNotifyMessage) JSONString() ([]byte, error)
  • func (notify *MQNotifyMessage) NewMessage(topic string, messageType string, payload interface{}) error
  • func (notify *MQNotifyMessage) WithJSONString(jsonbytes []byte) error
• type RocketmqKeeper
  • func (keeper *RocketmqKeeper) AddObservers(newObservers ...MQMessageObserver) error
  • func (keeper *RocketmqKeeper) NewMessage(topic string, messageType string, payload interface{}) (*MQNotifyMessage, error)
  • func (keeper *RocketmqKeeper) RemoveObservers(observerNames ...string) error
  • func (keeper *RocketmqKeeper) SendMessage(message *MQNotifyMessage) error

Constants

const (
	ENABLE  = "enable"
	DISABLE = "disable"

	MESSAGE_TYPE_TEST = "notify.test"

	NOTIFY_ONLINE  = "device.online"
	NOTIFY_OFFLINE = "device.offline"
	NOTIFY_NORMAL  = "message.normal"
)

const (
	ROCKETMQ_KEEPER = "zero.rocketmq.keeper"
)

Functions

func InitRocketMQ

func InitRocketMQ(newObservers ...MQMessageObserver)

func ShutdownNotifyConsumer

func ShutdownNotifyConsumer()

Types

type MQMessageObserver

type MQMessageObserver interface {
	Name() string
	OnMessage(*MQNotifyMessage) error
}

type MQNotifyMessage

type MQNotifyMessage struct {
	MessageId   string       `json:"messageId,omitempty"`
	Topic       string       `json:"topic,omitempty"`
	CreateTime  structs.Time `json:"createTime,omitempty"`
	MessageType string       `json:"messageType,omitempty"`
	Payload     interface{}  `json:"payload,omitempty"`
}

func (*MQNotifyMessage) JSONString

func (notify *MQNotifyMessage) JSONString() ([]byte, error)

func (*MQNotifyMessage) NewMessage

func (notify *MQNotifyMessage) NewMessage(topic string, messageType string, payload interface{}) error

func (*MQNotifyMessage) WithJSONString

func (notify *MQNotifyMessage) WithJSONString(jsonbytes []byte) error

type RocketmqKeeper

type RocketmqKeeper struct{}

func (*RocketmqKeeper) AddObservers

func (keeper *RocketmqKeeper) AddObservers(newObservers ...MQMessageObserver) error

func (*RocketmqKeeper) NewMessage

func (keeper *RocketmqKeeper) NewMessage(topic string, messageType string, payload interface{}) (*MQNotifyMessage, error)

func (*RocketmqKeeper) RemoveObservers

func (keeper *RocketmqKeeper) RemoveObservers(observerNames ...string) error

func (*RocketmqKeeper) SendMessage

func (keeper *RocketmqKeeper) SendMessage(message *MQNotifyMessage) error