diff options
author | Ask Solem <ask@celeryproject.org> | 2015-09-28 13:46:31 -0700 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2015-09-28 13:46:31 -0700 |
commit | 639a9cc0d3d8eab3f3945e0ebb901ba08e5bbe5a (patch) | |
tree | 4b7e3ad8ace0463a35fc530be87a37da4d2dd235 /kombu/transport/qpid.py | |
parent | cc075f1467c3f4ead534c78aa6344f2f6a2f6b79 (diff) | |
download | kombu-639a9cc0d3d8eab3f3945e0ebb901ba08e5bbe5a.tar.gz |
flakes
Diffstat (limited to 'kombu/transport/qpid.py')
-rw-r--r-- | kombu/transport/qpid.py | 23 |
1 files changed, 9 insertions, 14 deletions
diff --git a/kombu/transport/qpid.py b/kombu/transport/qpid.py index b50dee58..5dcb97d9 100644 --- a/kombu/transport/qpid.py +++ b/kombu/transport/qpid.py @@ -30,8 +30,6 @@ command: """ from __future__ import absolute_import -"""Kombu transport using a Qpid broker as a message store.""" - import fcntl import os import select @@ -46,6 +44,11 @@ from itertools import count import amqp.protocol +from kombu.five import Empty, items +from kombu.log import get_logger +from kombu.transport.virtual import Base64, Message +from kombu.transport import base + try: import qpidtoollibs except ImportError: # pragma: no cover @@ -58,25 +61,17 @@ except ImportError: # pragma: no cover ConnectionError = None QpidEmpty = None +# ## The Following Import Applies Monkey Patches at Import Time ## +import kombu.transport.qpid_patches # noqa +################################################################ + try: import qpid except ImportError: # pragma: no cover qpid = None - -from kombu.five import Empty, items -from kombu.log import get_logger -from kombu.transport.virtual import Base64, Message -from kombu.transport import base - - logger = get_logger(__name__) -# ## The Following Import Applies Monkey Patches at Import Time ## -import kombu.transport.qpid_patches # noqa -################################################################ - - DEFAULT_PORT = 5672 OBJECT_ALREADY_EXISTS_STRING = 'object already exists' |