diff --git a/bilean/common/messaging.py b/bilean/common/messaging.py index c59a8fd..06f19b1 100644 --- a/bilean/common/messaging.py +++ b/bilean/common/messaging.py @@ -66,7 +66,7 @@ def setup(url=None, optional=False): oslo_messaging.set_transport_defaults('bilean') exmods = ['bilean.common.exception'] try: - TRANSPORT = oslo_messaging.get_transport( + TRANSPORT = oslo_messaging.get_rpc_transport( cfg.CONF, url, allowed_remote_exmods=exmods) except oslo_messaging.InvalidTransportURL as e: TRANSPORT = None @@ -96,7 +96,7 @@ def get_transport(url=None, optional=False, cache=True): transport = TRANSPORTS.get(cache_key) if not transport or not cache: try: - transport = oslo_messaging.get_transport(cfg.CONF, url) + transport = oslo_messaging.get_rpc_transport(cfg.CONF, url) except oslo_messaging.InvalidTransportURL as e: if not optional or e.url: # NOTE(sileht): oslo_messaging is configured but unloadable diff --git a/bilean/notifier.py b/bilean/notifier.py index 545fce7..626109e 100644 --- a/bilean/notifier.py +++ b/bilean/notifier.py @@ -24,7 +24,7 @@ CONF.register_opts(notifier_opts) def get_transport(): - return oslo_messaging.get_transport(CONF) + return oslo_messaging.get_rpc_transport(CONF) class Notifier(object):