代码拉取完成,页面将自动刷新
package RabbitmqRoute
import kelleyRabbimqPool "gitee.com/tym_hmm/rabbitmq-pool-go"
type BaseConsumer struct {
TaskName string
ExchangeName string
ExChangeType string
VirtualHosts string
Queue string
RouteKey string
IsTry bool //是否重试
MaxReTry int32 //最大重式次数
IsAutoAck bool //是否自动确认
}
/**
发送消息到rmq
*/
func (a *BaseConsumer) Receive(rabbitMqPool *kelleyRabbimqPool.RabbitPool, successEvent func(data []byte, header map[string]interface{}, retryClient kelleyRabbimqPool.RetryClientInterface) bool, failEvent func(code int, err error)) {
normal := &kelleyRabbimqPool.ConsumeReceive{
ExchangeName: a.ExchangeName,
ExchangeType: a.ExChangeType,
Route: a.RouteKey,
QueueName: a.Queue,
IsTry: a.IsTry,
MaxReTry: a.MaxReTry,
IsAutoAck: a.IsAutoAck,
EventFail: func(code int, e error, data []byte) {
failEvent(code, e)
return
},
EventSuccess: func(data []byte, header map[string]interface{}, retryClient kelleyRabbimqPool.RetryClientInterface) bool {
return successEvent(data, header, retryClient)
},
}
rabbitMqPool.RegisterConsumeReceive(normal)
err := rabbitMqPool.RunConsume()
if err != nil {
failEvent(CODE_RABBITMQ_RECEIVED_ERROR, err)
return
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。