From efa792b95c0d8a7f4f575e5d4a9aa1ae88dce19e Mon Sep 17 00:00:00 2001
From: Ask Solem <ask@celeryproject.org>
Date: Mon, 22 Apr 2013 14:47:21 +0100
Subject: [PATCH] librabbitmq: Remove cyclic reference at connection close

---
 kombu/transport/librabbitmq.py | 1 +
 1 file changed, 1 insertion(+)

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):