core/src/main/java/org/infinispan/util/concurrent/CommandAckCollector.java
/**
    * Acknowledges an exception during the operation execution.
    * <p>
    * The collector is completed without waiting any further acknowledges.
    *
    * @param id         the id from {@link CommandInvocationId#getId()}.
    * @param throwable  the {@link Throwable}.
    * @param topologyId the topology id.
    */
Acknowledges an exception during the operation execution.

The collector is completed without waiting any further acknowledges.

@param id         the id from  CommandInvocationId#getId().
@param throwable  the  Throwable.
@param topologyId the topology id.
Acknowledges an exception during the operation execution . The collector is completed without waiting any further acknowledges . @param id the id from CommandInvocationId#getId () . @param throwable the Throwable . @param topologyId the topology id .
public void completeExceptionally(long id, Throwable throwable, int topologyId) {
      BaseCollector<?> collector = collectorMap.get(id);
      if (collector != null) {
         collector.completeExceptionally(throwable, topologyId);
      }
   }
public void completeExceptionally ( long id , Throwable throwable , int topologyId ) { BaseCollector < ? > collector = collectorMap . get ( id ) ; if ( collector != null ) { collector . completeExceptionally ( throwable , topologyId ) ; } }
Acknowledges an exception during the operation execution.
Acknowledges an exception during the operation execution .