protected void halt(final Throwable cause){
  halt=true;
  final boolean isFirstCause=firstCause.compareAndSet(null,cause);
  if (WARN)   try {
    if (!InnerCause.isInnerCause(cause,InterruptedException.class) && !InnerCause.isInnerCause(cause,CancellationException.class) && !InnerCause.isInnerCause(cause,ClosedByInterruptException.class)&& !InnerCause.isInnerCause(cause,RejectedExecutionException.class)&& !InnerCause.isInnerCause(cause,BufferClosedException.class)) {
      log.warn("orderIndex=" + orderIndex + ", partitionId="+ partitionId+ ", isFirstCause="+ isFirstCause+ " : "+ cause.getLocalizedMessage(),cause);
    }
  }
 catch (  Throwable ex) {
  }
}

protected void halt ( final Throwable cause ) { halt = true ; final boolean isFirstCause = firstCause . compareAndSet ( null , cause ) ; if ( WARN ) try { if ( ! InnerCause . isInnerCause ( cause , InterruptedException . class ) && ! InnerCause . isInnerCause ( cause , CancellationException . class ) && ! InnerCause . isInnerCause ( cause , ClosedByInterruptException . class ) && ! InnerCause . isInnerCause ( cause , RejectedExecutionException . class ) && ! InnerCause . isInnerCause ( cause , BufferClosedException . class ) ) { log . warn ( "orderIndex=" + orderIndex + ", partitionId=" + partitionId + ", isFirstCause=" + isFirstCause + " : " + cause . getLocalizedMessage ( ) , cause ) ; } } catch ( Throwable ex ) { } }
indicate that join processing should halt . this method is written defensively and will not throw anything .
