summaryrefslogtreecommitdiff
path: root/ceilometer/messaging.py
diff options
context:
space:
mode:
authorMehdi Abaakouk <sileht@redhat.com>2016-10-10 19:24:47 +0200
committerMehdi Abaakouk <sileht@redhat.com>2016-10-11 14:59:52 +0200
commit32c5d726470569f9a441346a0969f66fe5caab2a (patch)
tree07ba99b407f8ac1647e63fb4191b8e60729310d0 /ceilometer/messaging.py
parent5901528d1280ad8555d208ef86c614afd744c7c2 (diff)
downloadceilometer-32c5d726470569f9a441346a0969f66fe5caab2a.tar.gz
messaging: stop using global config
Change-Id: I97840aa9d1249deeba91dcdb6a5d23eca2fecdf1
Diffstat (limited to 'ceilometer/messaging.py')
-rw-r--r--ceilometer/messaging.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/ceilometer/messaging.py b/ceilometer/messaging.py
index 7b325077..8f8211be 100644
--- a/ceilometer/messaging.py
+++ b/ceilometer/messaging.py
@@ -13,7 +13,6 @@
# License for the specific language governing permissions and limitations
# under the License.
-from oslo_config import cfg
import oslo_messaging
from oslo_messaging import serializer as oslo_serializer
@@ -25,14 +24,14 @@ def setup():
oslo_messaging.set_transport_defaults('ceilometer')
-def get_transport(url=None, optional=False, cache=True):
+def get_transport(conf, url=None, optional=False, cache=True):
"""Initialise the oslo_messaging layer."""
global TRANSPORTS, DEFAULT_URL
cache_key = url or DEFAULT_URL
transport = TRANSPORTS.get(cache_key)
if not transport or not cache:
try:
- transport = oslo_messaging.get_transport(cfg.CONF, url)
+ transport = oslo_messaging.get_transport(conf, url)
except (oslo_messaging.InvalidTransportURL,
oslo_messaging.DriverLoadFailure):
if not optional or url: