def get_rpc_server(target, endpoint):
 serializer = RequestContextSerializer(JsonPayloadSerializer())
 access_policy = dispatcher.DefaultRPCAccessPolicy
 return oslo_messaging.get_rpc_server(TRANSPORT, target, [endpoint], executor='eventlet', serializer=serializer, access_policy=access_policy)

def get_rpc_server ( target , endpoint ) : serializer = RequestContextSerializer ( JsonPayloadSerializer ( ) ) access_policy = dispatcher . DefaultRPCAccessPolicy return oslo_messaging . get_rpc_server ( TRANSPORT , target , [ endpoint ] , executor = 'eventlet' , serializer = serializer , access_policy = access_policy )
return a configured oslo_messaging rpc server .