diff options
Diffstat (limited to 'oslo/messaging/_drivers')
| -rw-r--r-- | oslo/messaging/_drivers/amqpdriver.py | 3 | ||||
| -rw-r--r-- | oslo/messaging/_drivers/impl_fake.py | 3 |
2 files changed, 2 insertions, 4 deletions
diff --git a/oslo/messaging/_drivers/amqpdriver.py b/oslo/messaging/_drivers/amqpdriver.py index b20a61c..089601f 100644 --- a/oslo/messaging/_drivers/amqpdriver.py +++ b/oslo/messaging/_drivers/amqpdriver.py @@ -24,7 +24,6 @@ from oslo import messaging from oslo.messaging._drivers import amqp as rpc_amqp from oslo.messaging._drivers import base from oslo.messaging._drivers import common as rpc_common -from oslo.messaging import _urls as urls LOG = logging.getLogger(__name__) @@ -248,7 +247,7 @@ class AMQPDriverBase(base.BaseDriver): super(AMQPDriverBase, self).__init__(conf, url, default_exchange, allowed_remote_exmods) - self._default_exchange = urls.exchange_from_url(url, default_exchange) + self._default_exchange = default_exchange # FIXME(markmc): temp hack if self._default_exchange: diff --git a/oslo/messaging/_drivers/impl_fake.py b/oslo/messaging/_drivers/impl_fake.py index 42ddd86..6998262 100644 --- a/oslo/messaging/_drivers/impl_fake.py +++ b/oslo/messaging/_drivers/impl_fake.py @@ -22,7 +22,6 @@ import time from oslo import messaging from oslo.messaging._drivers import base -from oslo.messaging import _urls as urls class FakeIncomingMessage(base.IncomingMessage): @@ -92,7 +91,7 @@ class FakeDriver(base.BaseDriver): super(FakeDriver, self).__init__(conf, url, default_exchange, allowed_remote_exmods=[]) - self._default_exchange = urls.exchange_from_url(url, default_exchange) + self._default_exchange = default_exchange self._exchanges_lock = threading.Lock() self._exchanges = {} |