[ Cmii ] [ Octopus ] - hot fix manual shut down init queue

2024-04-09 10:19:01 +08:00
parent bcb46ec8aa
commit 83a676e321
1 changed files with 2 additions and 0 deletions
--- 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