events: close channel explicitly

Signed-off-by: Stephen J Day <stephen.day@docker.com>
2017-07-27 14:22:11 -07:00
parent d4349eff39
commit a1f7509648
1 changed files with 1 additions and 0 deletions
--- a/events/exchange.go
+++ b/events/exchange.go
@@ -98,6 +98,7 @@ func (e *Exchange) Subscribe(ctx context.Context, filters ...filters.Filter) (ch
 		defer close(errq)
 		defer e.broadcaster.Remove(queue)
 		defer queue.Close()
+		defer channel.Close()

 		var err error
 	loop: