Browse Source

Merge pull request #33 from iss0/main

Set channelManager config member
pull/36/head
Lane Wagner 4 years ago
committed by GitHub
parent
commit
897061950a
No known key found for this signature in database GPG Key ID: 4AEE18F83AFDEB23
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, connection: conn,
channel: ch, channel: ch,
channelMux: &sync.RWMutex{}, channelMux: &sync.RWMutex{},
config: conf,
notifyCancelOrClose: make(chan error), notifyCancelOrClose: make(chan error),
} }
go chManager.startNotifyCancelOrClosed() go chManager.startNotifyCancelOrClosed()


Loading…
Cancel
Save