Browse Source

Set channelManager config member

pull/33/head
Jan Steffen 4 years ago
parent
commit
94795df83b
No known key found for this signature in database GPG Key ID: 84092937C922A2BC
1 changed files with 1 additions and 0 deletions
  1. +1
    -0
      channel.go

+ 1
- 0
channel.go View File

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


Loading…
Cancel
Save