

def test_start_servers(self):
    self.flags(rpc_driver_queue_base='cells.intercell42', group='cells')
    fake_msg_runner = fakes.get_message_runner('api-cell')

    class FakeInterCellRPCDispatcher(object):

        def __init__(_self, msg_runner):
            self.assertEqual(fake_msg_runner, msg_runner)
    topic.stubs.Set(rpc_driver, 'InterCellRPCDispatcher', FakeInterCellRPCDispatcher)
    self.mox.StubOutWithMock(rpc, 'get_server')
    for message_type in messaging.MessageRunner.get_message_types():
        topic = ('cells.intercell42.' + message_type)
        target = oslo_messaging.Target(topic=topic, server=CONF.host)
        endpoints = [mox.IsA(FakeInterCellRPCDispatcher)]
        rpcserver = self.mox.CreateMockAnything()
        rpc.get_server(target, endpoints=endpoints).AndReturn(rpcserver)
        rpcserver.start()
    self.mox.ReplayAll()
    self.driver.start_servers(fake_msg_runner)

dataset/ETHPy150Open BU-NU-CLOUD-SP16/Trusted-Platform-Module-nova/nova/tests/unit/cells/test_cells_rpc_driver.py CellsRPCDriverTestCase.test_start_servers/VarMisuse@63/103 `self`->`topic`