diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-06-13 11:34:27 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-06-13 11:34:27 +0000 |
| commit | 27faee004af89be46f931b7ee37c22f0a91ac650 (patch) | |
| tree | a4c24243d1debf3edf469c5a2f9573f706603e0d /nova/openstack | |
| parent | a5cd0f86530013d62b066d7e917d167e521260b0 (diff) | |
| parent | 810edd4c649d4d378ce0d3872a4c9b558af27bd6 (diff) | |
| download | nova-27faee004af89be46f931b7ee37c22f0a91ac650.tar.gz nova-27faee004af89be46f931b7ee37c22f0a91ac650.tar.xz nova-27faee004af89be46f931b7ee37c22f0a91ac650.zip | |
Merge "Sync can_send_version() helper from oslo-incubator."
Diffstat (limited to 'nova/openstack')
| -rw-r--r-- | nova/openstack/common/rpc/proxy.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/nova/openstack/common/rpc/proxy.py b/nova/openstack/common/rpc/proxy.py index dcdfc0864..345457b69 100644 --- a/nova/openstack/common/rpc/proxy.py +++ b/nova/openstack/common/rpc/proxy.py @@ -76,6 +76,10 @@ class RpcProxy(object): """Return the topic to use for a message.""" return topic if topic else self.topic + def can_send_version(self, version): + return (not self.version_cap or + rpc_common.version_is_compatible(self.version_cap, version)) + @staticmethod def make_namespaced_msg(method, namespace, **kwargs): return {'method': method, 'namespace': namespace, 'args': kwargs} |