From 7ecbe1fae24cfdd88ee75241bcc1a25819625728 Mon Sep 17 00:00:00 2001 From: sebleier Date: Thu, 22 Jul 2010 12:27:33 -0700 Subject: [PATCH] Removed connection argument, since the connection already exists on the channel --- kombu/connection.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kombu/connection.py b/kombu/connection.py index e4709152..01d5cd47 100644 --- a/kombu/connection.py +++ b/kombu/connection.py @@ -62,7 +62,7 @@ class BrokerConnection(object): return self.backend.create_channel(self.connection) def drain_events(self, **kwargs): - return self.backend.drain_events(self.connection, **kwargs) + return self.backend.drain_events(**kwargs) def close(self): """Close the currently open connection."""