Merge pull request #21 from ryan961/main

fix: subscriber.ch isn't closed in the event of unexpected disconnection.
tx7do · Sep 14, 2022 · 47a0599 · 47a0599
2 parents 2f9eed1 + b31a12f
commit 47a0599
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/broker/rabbitmq/connection.go b/broker/rabbitmq/connection.go
@@ -169,6 +169,13 @@ func (r *rabbitConnection) reconnect(secure bool, config *amqp.Config) {
 			r.Unlock()
 		case err := <-notifyClose:
 			log.Error(err)
+
+			select {
+			case errs := <-chanNotifyClose:
+				log.Error(errs)
+			case <-time.After(time.Second):
+			}
+
 			r.Lock()
 			r.connected = false
 			r.waitConnection = make(chan struct{})