broker: prevent panic by checking for nil on channel close

lukasjarosch · Jul 21, 2020 · 5a7c27f · 5a7c27f
1 parent 87aa2d4
commit 5a7c27f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/broker/amqp/connection.go b/broker/amqp/connection.go
@@ -77,7 +77,9 @@ func (c *Connection) WaitForConnection() {
 func (c *Connection) Shutdown() {
  c.setConnected(false)
  c.cancel()
- _ = c.channel.Close()
+ if c.channel != nil {
+ _ = c.channel.Close()
+ }
 
  if c.IsConnected() {
  err := c.conn.Close()