mq

type Adapter int8

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 	主动关闭
	 */
	Close()

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

	/*
	* @brief 	消息发布接口定义(仅支持字符串类型消息)
	* @param 	strBindingKey 	路由Key
	* @param	strQueueName 	队列名称(redis/mqtt协议非必填)
	* @param	key 		消息标识(kafka必填，其他MQ填DEFAULT_DATA_KEY)
	* @param	value 		消息数据
	* @return   err 发布失败返回具体错误信息
	 */
	Publish(strBindingKey, strQueueName, key string, value string) (err error)

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

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

	/*
	* @brief 	获取当前MQ类型
	* @param 	adapter  MQ类型
	 */
	GetAdapter() (adapter Adapter)
}

type Instance func() IReactMQ

type Mode int8

type ReactHandler interface {
	OnConsume(adapter Adapter, strBindingKey, strQueueName, strKey string, strValue string)
}