diff options
| author | sebleier <sbleier@ellingtoncms.com> | 2010-07-22 12:27:33 -0700 |
|---|---|---|
| committer | sebleier <sbleier@ellingtoncms.com> | 2010-07-22 12:27:33 -0700 |
| commit | 7ecbe1fae24cfdd88ee75241bcc1a25819625728 (patch) | |
| tree | 21e038e9e0aa58a7360c867f70e0a816df014956 | |
| parent | 4dc37d70d99d42d74da458e0eff68b09da56a7c1 (diff) | |
| download | kombu-7ecbe1fae24cfdd88ee75241bcc1a25819625728.tar.gz | |
Removed connection argument, since the connection already exists on the channel
| -rw-r--r-- | kombu/connection.py | 2 |
1 files changed, 1 insertions, 1 deletions
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.""" |