fix merge conflict

This commit is contained in:
kiwiidb
2023-07-14 14:13:31 +02:00
parent 358007318a
commit 3da5d0c9a1

View File

@@ -61,6 +61,7 @@ func DialAMQP(uri string) (AMQPClient, error) {
reconFlag: atomic.Bool{},
}
err := client.connect()
client.listeners = []chan listenerMsg{}
go client.reconnectionLoop()
@@ -95,8 +96,6 @@ func (c *defaultAMQPCLient) connect() error {
c.publishChannel = publishChannel
c.notifyCloseChan = notifyCloseChan
c.listeners = []chan listenerMsg{}
return nil
}
@@ -120,33 +119,11 @@ func (c *defaultAMQPCLient) reconnectionLoop() error {
err := backoff.Retry(func() error {
c.logger.Info("amqp: trying to reconnect...")
conn, err := amqp.DialConfig(c.uri, amqp.Config{
Heartbeat: defaultHeartbeat,
Locale: defaultLocale,
Dial: amqp.DefaultDial(time.Second * 3),
})
err := c.connect()
if err != nil {
return err
}
consumeChannel, err := conn.Channel()
if err != nil {
return err
}
publishChannel, err := conn.Channel()
if err != nil {
return err
}
notifyCloseChan := make(chan *amqp.Error)
conn.NotifyClose(notifyCloseChan)
c.conn = conn
c.consumeChannel = consumeChannel
c.publishChannel = publishChannel
c.notifyCloseChan = notifyCloseChan
c.logger.Info("amqp: succesfully reconnected")
return nil