summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2012-08-24 15:40:35 +0100
committerAsk Solem <ask@celeryproject.org>2012-08-24 15:40:35 +0100
commit343b62e5adffe7d4b0768fcb684171f47481aa30 (patch)
tree2b28879accf61ef1fa97984c4f1a95e351faaad0
parentb7d8a7fe7bbe31043af20a80d5ad7aa85115f589 (diff)
downloadkombu-343b62e5adffe7d4b0768fcb684171f47481aa30.tar.gz
Tests passing
-rw-r--r--kombu/connection.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/kombu/connection.py b/kombu/connection.py
index c10a025e..f66bd1d7 100644
--- a/kombu/connection.py
+++ b/kombu/connection.py
@@ -29,6 +29,9 @@ from .utils import cached_property, retry_over_time
from .utils.compat import OrderedDict, LifoQueue as _LifoQueue
from .utils.url import parse_url
+RESOLVE_ALIASES = {'amqplib': 'amqp',
+ 'librabbitmq': 'amqp'}
+
_LOG_CONNECTION = os.environ.get('KOMBU_LOG_CONNECTION', False)
_LOG_CHANNEL = os.environ.get('KOMBU_LOG_CHANNEL', False)
@@ -405,6 +408,7 @@ class Connection(object):
def _info(self):
transport_cls = self.transport_cls or 'amqp'
+ transport_cls = RESOLVE_ALIASES.get(transport_cls, transport_cls)
D = self.transport.default_connection_params
hostname = self.hostname or D.get('hostname')
if self.uri_prefix: