From d36562ac5aa944f76b148cf1239564f43fde0b07 Mon Sep 17 00:00:00 2001 From: tengqm Date: Mon, 26 Jan 2015 17:08:25 +0800 Subject: [PATCH] Fixed reference to rpc_api --- bin/senlin-engine | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/bin/senlin-engine b/bin/senlin-engine index 4b2ee6bb2..84059efb4 100755 --- a/bin/senlin-engine +++ b/bin/senlin-engine @@ -33,12 +33,11 @@ if os.path.exists(os.path.join(POSSIBLE_TOPDIR, 'senlin', '__init__.py')): from oslo_config import cfg from oslo_i18n import _lazy +from senlin.common import attr from senlin.common import messaging from senlin.openstack.common import log as logging from senlin.openstack.common import service -from senlin.rpc import api as rpc_api - _lazy.enable_lazy() LOG = logging.getLogger('senlin.engine') @@ -51,7 +50,7 @@ if __name__ == '__main__': from senlin.engine import service as engine - srv = engine.EngineService(cfg.CONF.host, rpc_api.ENGINE_TOPIC) + srv = engine.EngineService(cfg.CONF.host, attr.ENGINE_TOPIC) launcher = service.launch(srv, workers=cfg.CONF.num_engine_workers) # the following periodic tasks are intended serve as HA checking # srv.create_periodic_tasks()