'Test that with cluster we create the rpc service.'

@ddt.data('1.3', '1.7')
@mock.patch('cinder.objects.Service.get_minimum_obj_version')
def test_start_rpc_and_init_host_cluster(self, obj_version, get_min_obj_mock):

    get_min_obj_mock.return_value = obj_version
    cluster = 'cluster@backend#pool'
    self.host = 'host@backend#pool'
    app = service.Service.create(host=self.host, binary='cinder-volume', cluster=cluster, topic=self.topic)
    self._check_rpc_servers_and_init_host(app, (obj_version != '1.3'), cluster)
