diff --git a/agent-go/rabbitmq/RabbitMsgQueue.go b/agent-go/rabbitmq/RabbitMsgQueue.go index 955bff1..c5b12ad 100644 --- a/agent-go/rabbitmq/RabbitMsgQueue.go +++ b/agent-go/rabbitmq/RabbitMsgQueue.go @@ -194,6 +194,8 @@ func (r *RabbitQueue) Close() error { func (r *RabbitQueue) Handle() chan bool { deliveries := r.Read(true) + // 2024年4月9日 + r.ConsumeOK = true foreverHandle := make(chan bool) // 死循环,处理Octopus Message