[ Cmii ] [ Operator ] - bug fix

agent-go/rabbitmq/RabbitMsgQueue.go

@@ -196,7 +196,7 @@ func (r *RabbitQueue) Handle() chan bool {
 
 	deliveries := r.Read(true)
 	// 2024年4月9日
-	r.ConsumeOK.Swap(true)
+	r.ConsumeOK.Store(true)
 
 	foreverHandle := make(chan bool)
 	// 死循环，处理Octopus Message
@@ -217,7 +217,7 @@ func (r *RabbitQueue) Handle() chan bool {
 
 			// 2024年4月9日
 			if !r.ConsumeOK.Load() {
-				log.InfoF("Rabbit Queue of [%s] [%s[ disconnect!", r.RabbitProp.ExchangeName, r.RabbitProp.QueueName)
+				log.InfoF("Rabbit Queue of [%s] [%s] disconnect!", r.RabbitProp.ExchangeName, r.RabbitProp.QueueName)
 				break
 			}
 		}