rabbit

Documentation

Index

• func NewMQ() mq.IReactMQ
• type RabbitMQ
  • func (this *RabbitMQ) Close()
  • func (this *RabbitMQ) Connect(mode mq.Mode, strURL string) (err error)
  • func (this *RabbitMQ) Consume(strBindingKey, strQueueName string, handler mq.ReactHandler) (err error)
  • func (this *RabbitMQ) Debug(enable bool)
  • func (this *RabbitMQ) GetAdapter() (adapter mq.Adapter)
  • func (this *RabbitMQ) IsClosed() bool
  • func (this *RabbitMQ) Publish(strBindingKey, strQueueName, key string, value string) (err error)
  • func (this *RabbitMQ) Reconnect() (err error)

Functions

func NewMQ

func NewMQ() mq.IReactMQ

Types

type RabbitMQ

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

func (*RabbitMQ) Close

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

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时，可调用此方法发起重连