etcd

package

v1.0.2 Latest Latest Go to latest Published: Mar 2, 2020 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewMQ() mq.IReactMQ

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

func (this *EtcdMQ) Connect(mode mq.Mode, strURL string) (err error)

func (this *EtcdMQ) Consume(strBindingKey, strQueueName string, cb mq.FnConsumeCb) (err error)

func (this *EtcdMQ) Debug(enable bool)

* @brief 开启或关闭调式模式 * @param enable true开启/false关闭

func (this *EtcdMQ) IsClosed() bool

判定是否服务器重启断开客户端连接

func (this *EtcdMQ) Publish(strRoutingKey, strData string) (err error)

func (this *EtcdMQ) Reconnect() (err error)

当调用Publish返回错误并且IsClosed()返回true时，可调用此方法发起重连