x/python-ganttclient
Code Issues Proposed changes

make default carrot again and delay the import in rpc/__init__.py

Browse Source
This commit is contained in:
Chris Behrens
2011-08-30 15:12:43 -07:00
parent 48b7d43be9
commit 1e5a2538e0
1 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
nova/rpc/__init__.py
View File

@@ -23,27 +23,33 @@ from nova import flags
FLAGS = flags.FLAGS FLAGS = flags.FLAGS
flags.DEFINE_string('rpc_backend', flags.DEFINE_string('rpc_backend',
'nova.rpc.impl_kombu', 'nova.rpc.impl_carrot',
"The messaging module to use, defaults to kombu.") "The messaging module to use, defaults to carrot.")
RPCIMPL = import_object(FLAGS.rpc_backend) _RPCIMPL = None
def get_impl():
global _RPCIMPL
if _RPCIMPL is None:
_RPCIMPL = import_object(FLAGS.rpc_backend)
return _RPCIMPL
def create_connection(new=True): def create_connection(new=True):
return RPCIMPL.create_connection(new=new) return get_impl().create_connection(new=new)
def call(context, topic, msg): def call(context, topic, msg):
return RPCIMPL.call(context, topic, msg) return get_impl().call(context, topic, msg)
def cast(context, topic, msg): def cast(context, topic, msg):
return RPCIMPL.cast(context, topic, msg) return get_impl().cast(context, topic, msg)
def fanout_cast(context, topic, msg): def fanout_cast(context, topic, msg):
return RPCIMPL.fanout_cast(context, topic, msg) return get_impl().fanout_cast(context, topic, msg)
def multicall(context, topic, msg): def multicall(context, topic, msg):
return RPCIMPL.multicall(context, topic, msg) return get_impl().multicall(context, topic, msg)