ClickandJoin
/
WebSocketServer
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

rabbitmq auto reconnect after connection lost

alpha
alex 2023-01-08 20:19:40 +01:00
parent eb1a18d03a
commit 7f249a5f0f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
modules/rabbitmq/helper.go
View File

@ -188,7 +188,7 @@ func ApiBroadcastMessagesHandling() {
// Re-set channel to receive notifications // Re-set channel to receive notifications
// The library closes this channel after abnormal shutdown // The library closes this channel after abnormal shutdown
channelClosedChannel = make(chan *amqp.Error, 1) channelClosedChannel = make(chan *amqp.Error, 1)
WebsocketClient.Channel.NotifyClose(channelClosedChannel) ApiBroadcastClient.Channel.NotifyClose(channelClosedChannel)
case msg := <-msgs: case msg := <-msgs:
var receivedMessage structs.ReceivedMessage var receivedMessage structs.ReceivedMessage