diff --git a/consume/egg_energy_auto_exchange_green_energy.go b/consume/egg_energy_auto_exchange_green_energy.go index 871057d..f83e903 100644 --- a/consume/egg_energy_auto_exchange_green_energy.go +++ b/consume/egg_energy_auto_exchange_green_energy.go @@ -44,8 +44,8 @@ func EggEnergyAutoExchangeGreenEnergyConsume(queue md.MqQueue) { "err": err.Error(), })) } - //_ = res.Reject(false) - err = res.Ack(true) + _ = res.Reject(true) //TODO::拒绝 + //err = res.Ack(true) fmt.Println("err ::: ", err) } else { panic(errors.New("error getting message")) diff --git a/consume/egg_energy_start_exchange_green_energy.go b/consume/egg_energy_start_exchange_green_energy.go index 1b41d5a..a77d10b 100644 --- a/consume/egg_energy_start_exchange_green_energy.go +++ b/consume/egg_energy_start_exchange_green_energy.go @@ -44,8 +44,8 @@ func EggEnergyStartExchangeGreenEnergyConsume(queue md.MqQueue) { "err": err.Error(), })) } - //_ = res.Reject(false) - err = res.Ack(true) + _ = res.Reject(true) //TODO::拒绝 + //err = res.Ack(true) fmt.Println("err ::: ", err) } else { panic(errors.New("error getting message")) diff --git a/go.mod b/go.mod index c7f57b0..a915886 100644 --- a/go.mod +++ b/go.mod @@ -8,7 +8,7 @@ go 1.19 require ( code.fnuoos.com/EggPlanet/egg_models.git v0.2.1-0.20241211055111-7c47b67b46d2 - code.fnuoos.com/EggPlanet/egg_system_rules.git v0.0.4-0.20241211143147-17b736995b8f + code.fnuoos.com/EggPlanet/egg_system_rules.git v0.0.4-0.20241211161130-ea373c032bd0 code.fnuoos.com/go_rely_warehouse/zyos_go_es.git v1.0.1-0.20241118083738-0f22da9ba0be code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git v0.0.5 github.com/boombuler/barcode v1.0.1