'Determines the RPC method, destination service and name.
The name is only used for logging, and it is the topic queue.'

def _cleanup_destination(self, clusters, service):

    if (service.binary == 'cinder-scheduler'):
        cleanup_rpc = self.sch_api.do_cleanup
        dest = None
        dest_name = service.host
    else:
        cleanup_rpc = self.volume_api.do_cleanup
        if service.is_clustered:
            dest = clusters[service.binary].get(service.cluster_name)
            if (not dest):
                dest = service.cluster
                clusters[service.binary][service.cluster_name] = dest
            dest_name = dest.name
        else:
            dest = service
            dest_name = service.host
    return (cleanup_rpc, dest, dest_name)
