summaryrefslogtreecommitdiff
path: root/kombu/transport/qpid.py
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2015-09-28 13:46:31 -0700
committerAsk Solem <ask@celeryproject.org>2015-09-28 13:46:31 -0700
commit639a9cc0d3d8eab3f3945e0ebb901ba08e5bbe5a (patch)
tree4b7e3ad8ace0463a35fc530be87a37da4d2dd235 /kombu/transport/qpid.py
parentcc075f1467c3f4ead534c78aa6344f2f6a2f6b79 (diff)
downloadkombu-639a9cc0d3d8eab3f3945e0ebb901ba08e5bbe5a.tar.gz
flakes
Diffstat (limited to 'kombu/transport/qpid.py')
-rw-r--r--kombu/transport/qpid.py23
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'