summaryrefslogtreecommitdiff
path: root/oslo/messaging/_drivers/amqpdriver.py
diff options
context:
space:
mode:
Diffstat (limited to 'oslo/messaging/_drivers/amqpdriver.py')
-rw-r--r--oslo/messaging/_drivers/amqpdriver.py3
1 files changed, 1 insertions, 2 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: