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()