Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type CbQueueSubscribe ¶
queue 订阅模式的回调
type Eventbus ¶
type Eventbus struct {
// contains filtered or unexported fields
}
func (*Eventbus) AsyncPub ¶
func (*Eventbus) QSub ¶
func (self *Eventbus) QSub(subj, q string, cb CbQueueSubscribe) error
func (*Eventbus) Sub ¶
func (self *Eventbus) Sub(subj string, cb CbSubscribe) error
type Mq ¶
type Mq struct {
// contains filtered or unexported fields
}
func NewMq ¶
PubAckWait MaxPubAcksInflight SetConnectionLostHandler
func (*Mq) QSub ¶
func (self *Mq) QSub(subj, qname, durable string, cb CbSubscribe) error
func (*Mq) Sub ¶
func (self *Mq) Sub(subj, durable string, cb CbSubscribe) error
Click to show internal directories.
Click to hide internal directories.