@@ -44,8 +44,8 @@ func EggEnergyAutoExchangeGreenEnergyConsume(queue md.MqQueue) { | |||||
"err": err.Error(), | "err": err.Error(), | ||||
})) | })) | ||||
} | } | ||||
//_ = res.Reject(false) | |||||
err = res.Ack(true) | |||||
_ = res.Reject(true) //TODO::拒绝 | |||||
//err = res.Ack(true) | |||||
fmt.Println("err ::: ", err) | fmt.Println("err ::: ", err) | ||||
} else { | } else { | ||||
panic(errors.New("error getting message")) | panic(errors.New("error getting message")) | ||||
@@ -44,8 +44,8 @@ func EggEnergyStartExchangeGreenEnergyConsume(queue md.MqQueue) { | |||||
"err": err.Error(), | "err": err.Error(), | ||||
})) | })) | ||||
} | } | ||||
//_ = res.Reject(false) | |||||
err = res.Ack(true) | |||||
_ = res.Reject(true) //TODO::拒绝 | |||||
//err = res.Ack(true) | |||||
fmt.Println("err ::: ", err) | fmt.Println("err ::: ", err) | ||||
} else { | } else { | ||||
panic(errors.New("error getting message")) | panic(errors.New("error getting message")) | ||||
@@ -8,7 +8,7 @@ go 1.19 | |||||
require ( | require ( | ||||
code.fnuoos.com/EggPlanet/egg_models.git v0.2.1-0.20241211055111-7c47b67b46d2 | 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_es.git v1.0.1-0.20241118083738-0f22da9ba0be | ||||
code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git v0.0.5 | code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git v0.0.5 | ||||
github.com/boombuler/barcode v1.0.1 | github.com/boombuler/barcode v1.0.1 | ||||