diff --git a/events/exchange.go b/events/exchange.go
index e78e5c204..5b8891ae4 100644
--- 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: