diff options
| author | Ask Solem <ask@celeryproject.org> | 2013-02-12 16:37:01 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2013-02-12 16:37:01 +0000 |
| commit | b0565f750929275b035108de4880e78c1327dbd0 (patch) | |
| tree | 8971fe3047b305322f0d160b7523d019bace76bd /kombu/transport/pyamqp.py | |
| parent | d84c1fca5b7fb50610f90f2447ba30d9641e5fb4 (diff) | |
| download | kombu-b0565f750929275b035108de4880e78c1327dbd0.tar.gz | |
python 3 fixes
Diffstat (limited to 'kombu/transport/pyamqp.py')
| -rw-r--r-- | kombu/transport/pyamqp.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kombu/transport/pyamqp.py b/kombu/transport/pyamqp.py index 06d6fc60..27fb81c8 100644 --- a/kombu/transport/pyamqp.py +++ b/kombu/transport/pyamqp.py @@ -14,6 +14,7 @@ from kombu.exceptions import ( StdChannelError, VersionMismatch, ) +from kombu.five import items from kombu.utils.amq_manager import get_manager from . import base @@ -96,7 +97,7 @@ class Transport(base.Transport): def establish_connection(self): """Establish connection to the AMQP broker.""" conninfo = self.client - for name, default_value in self.default_connection_params.items(): + for name, default_value in items(self.default_connection_params): if not getattr(conninfo, name, None): setattr(conninfo, name, default_value) if conninfo.hostname == 'localhost': |