private boolean pause(){
  try {
    U.await(pauseLatch,REMAP_PAUSE,MILLISECONDS);
    return true;
  }
 catch (  IgniteInterruptedCheckedException e) {
    onDone(e);
    return false;
  }
}

private boolean pause ( ) { try { U . await ( pauseLatch , REMAP_PAUSE , MILLISECONDS ) ; return true ; } catch ( IgniteInterruptedCheckedException e ) { onDone ( e ) ; return false ; } }
pause to avoid crazy resending in case of topology changes .
