mq

Documentation

Index

• Variables
• type CallbackFunc
• type MQ
  • func NewMQ() MQ
• type Message

Variables

var GlobalMQ = NewMQ()

Types

type CallbackFunc

type CallbackFunc func(Message)

type MQ

type MQ interface {
	rpc.Notifier

	// 发布一个消息
	Publish(string, Message)

	// 订阅一个消息主题
	Subscribe(string, int) <-chan Message

	// 订阅一个消息主题，注册触发回调函数
	SubscribeCallback(string, CallbackFunc)

	// 取消订阅一个消息主题
	Unsubscribe(string, <-chan Message)
}

MQ 消息队列

func NewMQ

func NewMQ() MQ

type Message

type Message struct {
	// 消息触发者
	TriggeredBy string

	// 事件标识
	Event string

	// 消息正文
	Content interface{}
}

Message 消息事件正文