diff options
| author | Ask Solem <ask@celeryproject.org> | 2012-08-24 15:40:35 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2012-08-24 15:40:35 +0100 |
| commit | 343b62e5adffe7d4b0768fcb684171f47481aa30 (patch) | |
| tree | 2b28879accf61ef1fa97984c4f1a95e351faaad0 | |
| parent | b7d8a7fe7bbe31043af20a80d5ad7aa85115f589 (diff) | |
| download | kombu-343b62e5adffe7d4b0768fcb684171f47481aa30.tar.gz | |
Tests passing
| -rw-r--r-- | kombu/connection.py | 4 |
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: |
