openstack
/
cloudkitty
Code Issues Proposed changes

Merge "Set access_policy for messaging's dispatcher"

This commit is contained in:
Jenkins 2017-06-22 08:43:47 +00:00 committed by Gerrit Code Review
parent bc1678320a 32e768c766
commit 2b513f7414
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloudkitty/messaging.py
View File

@ -15,6 +15,7 @@
from oslo_config import cfg
import oslo_messaging
from oslo_messaging.rpc import dispatcher
DEFAULT_URL = "__default__"
RPC_TARGET = None
@ -60,11 +61,13 @@ def get_client(version_cap=None):
def get_server(target=None, endpoints=None):
access_policy = dispatcher.DefaultRPCAccessPolicy
transport = get_transport()
if not target:
target = get_target()
return oslo_messaging.get_rpc_server(transport, target,
endpoints, executor='eventlet')
endpoints, executor='eventlet',
access_policy=access_policy)
def cleanup():

2
requirements.txt
View File

@ -19,7 +19,7 @@ oslo.concurrency>=3.5.0 # Apache-2.0
oslo.db>=4.1.0 # Apache-2.0
oslo.i18n>=2.1.0 # Apache-2.0
oslo.log>=1.14.0 # Apache-2.0
oslo.messaging>=5.2.0 # Apache-2.0
oslo.messaging>=5.11.0 # Apache-2.0
oslo.middleware>=3.0.0 # Apache-2.0
oslo.policy>=0.5.0 # Apache-2.0
oslo.utils>=3.5.0 # Apache-2.0