Set access_policy for messaging's dispatcher
oslo.messaging allow dispatcher to restrict endpoint methods since 5.11.0 in d3a8f280ebd6fd12865fd20c4d772774e39aefa2, set with DefaultRPCAccessPolicy to fix FutureWarning like: FutureWarning: The access_policy argument is changing its default value to <class 'oslo_messaging.rpc.dispatcher.DefaultRPCAccessPolicy'> in version '?', please update the code to explicitly set None as the value: access_policy defaults to LegacyRPCAccessPolicy which exposes private methods. Explicitly set access_policy to DefaultRPCAccessPolicy or ExplicitRPCAccessPolicy. Change-Id: I194187ec697ac0e0ecbc9fa98a1f8c0a6229a8ee
This commit is contained in:
parent
c2230f98b8
commit
fac2c28ba0
@ -19,6 +19,7 @@ Queue objects for Barbican
|
||||
import oslo_messaging as messaging
|
||||
from oslo_messaging.notify import dispatcher as notify_dispatcher
|
||||
from oslo_messaging.notify import listener
|
||||
from oslo_messaging.rpc import dispatcher
|
||||
|
||||
from barbican.common import config
|
||||
from barbican.common import exception
|
||||
@ -77,11 +78,13 @@ def get_client(target=None, version_cap=None, serializer=None):
|
||||
|
||||
|
||||
def get_server(target, endpoints, serializer=None):
|
||||
access_policy = dispatcher.DefaultRPCAccessPolicy
|
||||
return messaging.get_rpc_server(TRANSPORT,
|
||||
target,
|
||||
endpoints,
|
||||
executor='eventlet',
|
||||
serializer=serializer)
|
||||
serializer=serializer,
|
||||
access_policy=access_policy)
|
||||
|
||||
|
||||
def get_notification_target():
|
||||
|
Loading…
x
Reference in New Issue
Block a user