openstack
/
karbor
Code Issues Proposed changes

Merge "Set access_policy for messaging's dispatcher"

This commit is contained in:
Jenkins 2017-01-13 02:19:59 +00:00 committed by Gerrit Code Review
parent 6b776480f5 f6eb328dc8
commit fccbb83e62
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
karbor/rpc.py
View File

@ -25,6 +25,7 @@ __all__ = [
from oslo_config import cfg
import oslo_messaging as messaging
from oslo_messaging.rpc import dispatcher
from oslo_serialization import jsonutils
import karbor.context
@ -122,11 +123,13 @@ 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.DefaultRPCAccessPolicy
return messaging.get_rpc_server(TRANSPORT,
target,
endpoints,
executor='eventlet',
serializer=serializer)
serializer=serializer,
access_policy=access_policy)
def get_notifier(service=None, host=None, publisher_id=None):