aljaz/lndhub.go
1
1
Fork 0
mirror of https://github.com/getAlby/lndhub.go.git synced 2026-02-07 05:54:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Oopsie poopsie

Browse Source
This commit is contained in:
Lucas Rouckhout
2023-07-14 14:22:49 +02:00
parent cb0b09599f
commit 2cd6c6f02a
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
rabbitmq/amqp.go
View File

@@ -61,6 +61,10 @@ func DialAMQP(uri string) (AMQPClient, error) {
reconFlag: atomic.Bool{},
}
err := client.connect()
if err != nil {
return client, err
}
client.listeners = []chan listenerMsg{}
go client.reconnectionLoop()
@@ -114,10 +118,6 @@ func (c *defaultAMQPCLient) reconnectionLoop() error {
c.logger.Info("amqp: trying to reconnect...")
err := backoff.Retry(c.connect, expontentialBackoff)
c.reconFlag.Store(false)
c.logger.Info("amqp: succesfully reconnected")
if err != nil {
for _, listener := range c.listeners {
listener <- msgClose
@@ -126,6 +126,11 @@ func (c *defaultAMQPCLient) reconnectionLoop() error {
return err
}
c.reconFlag.Store(false)
c.logger.Info("amqp: succesfully reconnected")
for _, listener := range c.listeners {
listener <- msgReconnect
}