From 7f249a5f0ff58b346dd9bb1676927293a7789068 Mon Sep 17 00:00:00 2001 From: alex Date: Sun, 8 Jan 2023 20:19:40 +0100 Subject: [PATCH] rabbitmq auto reconnect after connection lost --- modules/rabbitmq/helper.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/rabbitmq/helper.go b/modules/rabbitmq/helper.go index 22251de..2bb1e6e 100644 --- a/modules/rabbitmq/helper.go +++ b/modules/rabbitmq/helper.go @@ -188,7 +188,7 @@ func ApiBroadcastMessagesHandling() { // Re-set channel to receive notifications // The library closes this channel after abnormal shutdown channelClosedChannel = make(chan *amqp.Error, 1) - WebsocketClient.Channel.NotifyClose(channelClosedChannel) + ApiBroadcastClient.Channel.NotifyClose(channelClosedChannel) case msg := <-msgs: var receivedMessage structs.ReceivedMessage