Merge "Add rpc method namespace support."

1 files changed, 5 insertions, 1 deletions

diff --git a/openstack/common/rpc/proxy.py b/openstack/common/rpc/proxy.py
index 822248d..284f375 100644
--- a/openstack/common/rpc/proxy.py
+++ b/openstack/common/rpc/proxy.py
@@ -59,8 +59,12 @@ class RpcProxy(object):
         return topic if topic else self.topic
 
     @staticmethod
+    def make_namespaced_msg(method, namespace, **kwargs):
+        return {'method': method, 'namespace': namespace, 'args': kwargs}
+
+    @staticmethod
     def make_msg(method, **kwargs):
-        return {'method': method, 'args': kwargs}
+        return RpcProxy.make_namespaced_msg(method, None, **kwargs)
 
     def call(self, context, msg, topic=None, version=None, timeout=None):
         """rpc.call() a remote method.