Documentation
¶
Index ¶
Constants ¶
View Source
const ( ConOk = Status(0) ConFail = Status(1) )
View Source
const ( ConTypePush = Type(0) ConTypePull = Type(1) )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer interface { Start(cfg server.MqConfig) error Stop() /* 建议外面使用 go goroutine */ Subscribe(topic Topic, exp Expression, call func(msg *Message) Status) error }
func NewConsumer ¶
func NewPullConsumer ¶
func NewPullConsumer() Consumer
func NewPushConsumer ¶
func NewPushConsumer() Consumer
type Expression ¶
Click to show internal directories.
Click to hide internal directories.