class ClientConnectionDropTask extends VisorMultiNodeTask<KillClientCommandArg, Void, Boolean> {
    /** */
    private static final long serialVersionUID = 0L;

    /** {@inheritDoc} */
    @Override protected VisorJob<KillClientCommandArg, Boolean> job(KillClientCommandArg arg) {
        return new ClientConnectionDropJob(arg, debug);
    }

    /** {@inheritDoc} */
    @Override protected Void reduce0(List<ComputeJobResult> results) throws IgniteException {<FILL_FUNCTION_BODY>}

    /**
     * Job to cancel client connection(s).
     */
    private static class ClientConnectionDropJob extends VisorJob<KillClientCommandArg, Boolean> {
        /** */
        private static final long serialVersionUID = 0L;

        /**
         * Create job with specified argument.
         *
         * @param arg Job argument.
         * @param debug Flag indicating whether debug information should be printed into node log.
         */
        protected ClientConnectionDropJob(@Nullable KillClientCommandArg arg, boolean debug) {
            super(arg, debug);
        }

        /** {@inheritDoc} */
        @Override protected Boolean run(@Nullable KillClientCommandArg arg) throws IgniteException {
            if (arg == null)
                return false;

            ClientProcessorMXBean bean = ignite.context().clientListener().mxBean();

            if (!"ALL".equals(arg.connectionId()))
                return bean.dropConnection(Long.parseLong(arg.connectionId()));

            bean.dropAllConnections();

            return true;
        }
    }
}

        boolean res = false;

        for (ComputeJobResult jobRes : results) {
            if (jobRes.getException() != null)
                throw jobRes.getException();

            res |= jobRes.<Boolean>getData();
        }

        if (!res)
            throw new IgniteException("No connection was dropped");

        return null;
    
<methods>public non-sealed void <init>() ,public Map<? extends org.apache.ignite.compute.ComputeJob,org.apache.ignite.cluster.ClusterNode> map(List<org.apache.ignite.cluster.ClusterNode>, VisorTaskArgument<org.apache.ignite.internal.management.kill.KillClientCommandArg>) ,public final java.lang.Void reduce(List<org.apache.ignite.compute.ComputeJobResult>) ,public org.apache.ignite.compute.ComputeJobResultPolicy result(org.apache.ignite.compute.ComputeJobResult, List<org.apache.ignite.compute.ComputeJobResult>) <variables>protected boolean debug,protected transient org.apache.ignite.internal.IgniteEx ignite,protected long start,protected org.apache.ignite.internal.management.kill.KillClientCommandArg taskArg