From fac2c28ba0f0757d84523eda9643563d313af098 Mon Sep 17 00:00:00 2001
From: shubhendu <shubhendu.poothia@nectechnologies.in>
Date: Fri, 28 Apr 2017 20:16:42 +0530
Subject: [PATCH] Set access_policy for messaging's dispatcher

oslo.messaging allow dispatcher to restrict endpoint methods
since 5.11.0 in d3a8f280ebd6fd12865fd20c4d772774e39aefa2, set with
DefaultRPCAccessPolicy to fix FutureWarning like:

FutureWarning: The access_policy argument is changing its default
value to <class 'oslo_messaging.rpc.dispatcher.DefaultRPCAccessPolicy'>
in version '?', please update the code to explicitly set None as the
value: access_policy defaults to LegacyRPCAccessPolicy which exposes
private methods. Explicitly set access_policy to DefaultRPCAccessPolicy
or ExplicitRPCAccessPolicy.

Change-Id: I194187ec697ac0e0ecbc9fa98a1f8c0a6229a8ee
---
 barbican/queue/__init__.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/barbican/queue/__init__.py b/barbican/queue/__init__.py
index e14854d8e..d9ff8e38a 100644
--- a/barbican/queue/__init__.py
+++ b/barbican/queue/__init__.py
@@ -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():