rabbit

func (*RabbitMQ) Close ¶ added in v1.0.9

func (this *RabbitMQ) Close()

关闭MQ

func (*RabbitMQ) Connect ¶

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

func (*RabbitMQ) Consume ¶

func (this *RabbitMQ) Consume(strBindingKey, strQueueName string, handler mq.ReactHandler) (err error)

* @brief 消息消费接口定义 * @param strBindingKey 队列绑定Key * @param strQueueName 队列名称 * @param handler 消费回调处理对象 * @return err 成功返回nil，失败返回返回具体错误信息 * @remark 服务器异常或重启时内部会自动重连服务器

func (*RabbitMQ) Debug ¶

func (this *RabbitMQ) Debug(enable bool)

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

func (*RabbitMQ) GetAdapter ¶ added in v1.0.9

func (this *RabbitMQ) GetAdapter() (adapter mq.Adapter)

* @brief 获取当前MQ类型 * @param adapter MQ类型

func (*RabbitMQ) IsClosed ¶

func (this *RabbitMQ) IsClosed() bool

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

func (*RabbitMQ) Publish ¶

func (this *RabbitMQ) Publish(strBindingKey, strQueueName, key string, value string) (err error)

* @brief 消息发布接口定义(仅支持字符串类型消息) * @param strBindingKey 队列绑定Key(topic) * @param strQueueName 队列名称(group) * @param key 消息KEY(仅kafka必填，其他MQ类型默认填PRODUCER_KEY_NULL) * @param value 消息数据 * @return err 发布失败返回具体错误信息

func (*RabbitMQ) Reconnect ¶

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

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