@Override
  public void enqueueRepairCluster(final int clusterId) {
    if (!active)
      return;

    if (clusterId < -1)
      // SKIP TRANSACTIONAL RIDS
      return;

    recordProcessed.incrementAndGet();

    // ADD CLUSTER TO REPAIR
    clusters.put(clusterId, Boolean.TRUE);
  }
@Override
  public void enqueueRepairCluster(final int clusterId) {
    if (!active)
      return;

    if (clusterId < -1)
      
      return;

    recordProcessed.incrementAndGet();

    
    clusters.put(clusterId, Boolean.TRUE);
  }
@ Override public void enqueueRepairCluster ( final int clusterId ) { if ( ! active ) return ; if ( clusterId < - 1 ) // SKIP TRANSACTIONAL RIDS return ; recordProcessed . incrementAndGet ( ) ; // ADD CLUSTER TO REPAIR clusters . put ( clusterId , Boolean . TRUE ) ; }
Enqueues the request to repair a cluster. The decision about repairing is taken by the timer task.

@param clusterId Broken cluster id to start repairing
Enqueues the request to repair a cluster . The decision about repairing is taken by the timer task .