diff --git a/kombu/transport/librabbitmq.py b/kombu/transport/librabbitmq.py
index 818acc77..e06dae82 100644
--- a/kombu/transport/librabbitmq.py
+++ b/kombu/transport/librabbitmq.py
@@ -118,6 +118,7 @@ class Transport(base.Transport):
 
     def close_connection(self, connection):
         """Close the AMQP broker connection."""
+        self.client.drain_events = None
         connection.close()
 
     def verify_connection(self, connection):