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()