436437438439440441442443444445446
@Override public void run() { NodeProbe probe = clientProvider.getProbe(address); if (probe != null) { try { probe.decommission(); } catch (Exception e) { log.error("Failed to decomission " + address, e); } } }