Remove usage of oslo.messaging deprecated transport method.
Since few months oslo.messaging project have deprecated the get_transport method from the transport layer module. Move get_transport to get_rpc_transport. Change-Id: Ic30402b27b926dab517a4bb70ee5b436df98c73a
This commit is contained in:
parent
31842b6f3d
commit
9077f4df1d
@ -66,7 +66,7 @@ def setup(url=None, optional=False):
|
|||||||
oslo_messaging.set_transport_defaults('bilean')
|
oslo_messaging.set_transport_defaults('bilean')
|
||||||
exmods = ['bilean.common.exception']
|
exmods = ['bilean.common.exception']
|
||||||
try:
|
try:
|
||||||
TRANSPORT = oslo_messaging.get_transport(
|
TRANSPORT = oslo_messaging.get_rpc_transport(
|
||||||
cfg.CONF, url, allowed_remote_exmods=exmods)
|
cfg.CONF, url, allowed_remote_exmods=exmods)
|
||||||
except oslo_messaging.InvalidTransportURL as e:
|
except oslo_messaging.InvalidTransportURL as e:
|
||||||
TRANSPORT = None
|
TRANSPORT = None
|
||||||
@ -96,7 +96,7 @@ def get_transport(url=None, optional=False, cache=True):
|
|||||||
transport = TRANSPORTS.get(cache_key)
|
transport = TRANSPORTS.get(cache_key)
|
||||||
if not transport or not cache:
|
if not transport or not cache:
|
||||||
try:
|
try:
|
||||||
transport = oslo_messaging.get_transport(cfg.CONF, url)
|
transport = oslo_messaging.get_rpc_transport(cfg.CONF, url)
|
||||||
except oslo_messaging.InvalidTransportURL as e:
|
except oslo_messaging.InvalidTransportURL as e:
|
||||||
if not optional or e.url:
|
if not optional or e.url:
|
||||||
# NOTE(sileht): oslo_messaging is configured but unloadable
|
# NOTE(sileht): oslo_messaging is configured but unloadable
|
||||||
|
@ -24,7 +24,7 @@ CONF.register_opts(notifier_opts)
|
|||||||
|
|
||||||
|
|
||||||
def get_transport():
|
def get_transport():
|
||||||
return oslo_messaging.get_transport(CONF)
|
return oslo_messaging.get_rpc_transport(CONF)
|
||||||
|
|
||||||
|
|
||||||
class Notifier(object):
|
class Notifier(object):
|
||||||
|
Loading…
Reference in New Issue
Block a user