Integration with oslo.messaging library

Port Trove to use oslo messaging library instead of obsolete messaging
code from oslo incubator.

Change-Id: Ibd886f3cb4a45250c7c434b3af711abee266671c
Implements: blueprint rpc-versioning

1 files changed, 7 insertions, 5 deletions

diff --git a/run_tests.py b/run_tests.py
index 542144bf..64dbacdd 100644
--- a/run_tests.py
+++ b/run_tests.py
@@ -25,12 +25,14 @@ import traceback
 
 from trove.common import cfg
 from trove.common import utils
+from trove.common.rpc import service as rpc_service
+from trove.common.rpc import version as rpc_version
 from trove.openstack.common import log as logging
 from trove.tests.config import CONFIG
+from trove import rpc
 from wsgi_intercept.httplib2_intercept import install as wsgi_install
 import proboscis
 import wsgi_intercept
-from trove.openstack.common.rpc import service as rpc_service
 
 import eventlet
 eventlet.monkey_patch(thread=False)
@@ -63,11 +65,11 @@ def initialize_trove(config_file):
              default_config_files=[config_file])
     logging.setup(None)
     topic = CONF.taskmanager_queue
+    rpc.init(CONF)
 
-    from trove.taskmanager import manager
-    manager_impl = manager.Manager()
-    taskman_service = rpc_service.Service(None, topic=topic,
-                                          manager=manager_impl)
+    taskman_service = rpc_service.RpcService(
+        None, topic=topic, rpc_api_version=rpc_version.RPC_API_VERSION,
+        manager='trove.taskmanager.manager.Manager')
     taskman_service.start()
 
     return pastedeploy.paste_deploy_app(config_file, 'trove', {})