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