From 83a676e321f7e257445614d81e37c4c9d777e4f7 Mon Sep 17 00:00:00 2001
From: zeaslity <ice@qq.com>
Date: Tue, 9 Apr 2024 10:19:01 +0800
Subject: [PATCH] [ Cmii ] [ Octopus ] - hot fix manual shut down init queue

---
 agent-go/rabbitmq/RabbitMsgQueue.go | 2 ++
 1 file changed, 2 insertions(+)

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