From 94795df83b146d18b6ac2b5c930afaab09b89649 Mon Sep 17 00:00:00 2001 From: Jan Steffen Date: Fri, 16 Jul 2021 13:29:29 +0200 Subject: [PATCH] Set channelManager config member --- channel.go | 1 + 1 file changed, 1 insertion(+) diff --git a/channel.go b/channel.go index 3f2c598..58e40ad 100644 --- a/channel.go +++ b/channel.go @@ -30,6 +30,7 @@ func newChannelManager(url string, conf amqp.Config, log Logger) (*channelManage connection: conn, channel: ch, channelMux: &sync.RWMutex{}, + config: conf, notifyCancelOrClose: make(chan error), } go chManager.startNotifyCancelOrClosed()