openstack
/
barbican
Code Issues Proposed changes

Merge "Set access_policy for messaging's dispatcher"

This commit is contained in:
Jenkins 2017-04-29 22:27:24 +00:00 committed by Gerrit Code Review
parent f60dcc9a4e fac2c28ba0
commit bd5b8e32f8
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
barbican/queue/__init__.py
View File

@ -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():