Merge "Switched rpc access policy to DefaultRPCAccessPolicy"
This commit is contained in:
commit
2e7301f7a9
|
@ -205,7 +205,7 @@ def get_client(target, version_cap=None, serializer=None):
|
|||
def get_server(target, endpoints, serializer=None):
|
||||
assert TRANSPORT is not None
|
||||
serializer = RequestContextSerializer(serializer)
|
||||
access_policy = dispatcher.LegacyRPCAccessPolicy
|
||||
access_policy = dispatcher.DefaultRPCAccessPolicy
|
||||
return oslo_messaging.get_rpc_server(TRANSPORT, target, endpoints,
|
||||
'eventlet', serializer,
|
||||
access_policy=access_policy)
|
||||
|
|
|
@ -168,7 +168,7 @@ class TestRPC(base.DietTestCase):
|
|||
server = rpc.get_server(tgt, ends, serializer='foo')
|
||||
|
||||
mock_ser.assert_called_once_with('foo')
|
||||
access_policy = dispatcher.LegacyRPCAccessPolicy
|
||||
access_policy = dispatcher.DefaultRPCAccessPolicy
|
||||
mock_get.assert_called_once_with(rpc.TRANSPORT, tgt, ends,
|
||||
'eventlet', ser,
|
||||
access_policy=access_policy)
|
||||
|
|
Loading…
Reference in New Issue