diff --git a/consume/egg_energy_team_assistance_consume.go b/consume/egg_energy_team_assistance_consume.go index 28f5865..0ada410 100644 --- a/consume/egg_energy_team_assistance_consume.go +++ b/consume/egg_energy_team_assistance_consume.go @@ -29,7 +29,7 @@ func EggEnergyTeamAssistanceConsume(queue md.MqQueue) { //1、将自己绑定到交换机上 ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) //2、取出数据进行消费 - ch.Qos(2) + ch.Qos(10) delivery := ch.Consume(queue.Name, false) egg_system_rules.Init(cfg.RedisAddr) @@ -56,7 +56,6 @@ func EggEnergyTeamAssistanceConsume(queue md.MqQueue) { } func handleEggEnergyTeamAssistanceDataConsume(msgData []byte) error { - return nil time.Sleep(time.Duration(10) * time.Millisecond) //休眠100毫秒 // 1.解析mq中queue的数据结构体 var msg *md2.EggEnergyTeamAssistanceReq diff --git a/consume/md/consume_key.go b/consume/md/consume_key.go index 9eac960..2e998b8 100644 --- a/consume/md/consume_key.go +++ b/consume/md/consume_key.go @@ -274,7 +274,7 @@ var RabbitMqQueueKeyList = []*MqQueue{ }, { ExchangeName: "egg.energy", - Name: "egg_energy_team_assistance", + Name: "egg_energy_team_assistance_back", Type: DirectQueueType, IsPersistent: false, RoutKey: "egg_energy_team_assistance",