mq

type Adapter int8

type FnConsumeCb func(strBody string) //消费者数据回调通知

type IReactMQ interface {
	/*
	* @brief 	MQ服务器连接接口定义
	* @param 	strUrl 连接服务器URL(格式规范 [amqp|redis|rocket|kafka|mqtt]://user:password@host:port)
	* @return 	err 连接失败返回具体错误信息
	 */
	Connect(mode Mode, strURL string) (err error)

	/*
	* @brief 	MQ服务器重新连接接口定义
	* @param
	* @return 	err 连接失败返回具体错误信息
	* @remark   当Publish返回错误且IsClosed()方法亦返回true时调用此方法重连MQ服务器
	 */
	Reconnect() (err error)

	/*
	* @brief 	判定是否MQ服务器断开连接（异常宕机或重启）
	* @param
	* @return 	远程服务器连接断开返回true，否则返回false
	 */
	IsClosed() bool

	/*
	* @brief 	消息发布接口定义(仅支持字符串类型消息)
	* @param 	strRoutingKey 	路由Key
	* @param	strData 		消息数据
	* @return   err 发布失败返回具体错误信息
	 */
	Publish(strRoutingKey, strData string) (err error)

	/*
	* @brief 	消息消费接口定义
	* @param 	strBidingKey 	队列绑定Key
	* @param	strQueueName 	队列名称(redis/mqtt协议非必填)
	* @return   err 成功返回nil，失败返回返回具体错误信息
	* @remark   服务器异常或重启时内部会自动重连服务器
	 */
	Consume(strBidingKey, strQueueName string, cb FnConsumeCb) (err error)

	/*
	* @brief 	开启或关闭调式模式
	* @param 	enable 	true开启/false关闭
	 */
	Debug(enable bool)
}

type Instance func() IReactMQ

type Mode int8