core/src/main/java/org/infinispan/util/concurrent/CommandAckCollector.java
/**
    * Creates a collector for {@link org.infinispan.commands.write.PutMapCommand}.
    *
    * @param id         the id from {@link CommandInvocationId#getId()}.
    * @param primary    a primary owners collection..
    * @param backups    a map between a backup owner and its segments affected.
    * @param topologyId the current topology id.
    */
Creates a collector for  org.infinispan.commands.write.PutMapCommand.
@param id         the id from  CommandInvocationId#getId().
@param primary    a primary owners collection
@param backups    a map between a backup owner and its segments affected.
@param topologyId the current topology id.
Creates a collector for org . infinispan . commands . write . PutMapCommand . @param id the id from CommandInvocationId#getId () . @param primary a primary owners collection @param backups a map between a backup owner and its segments affected . @param topologyId the current topology id .
public Collector<Map<Object, Object>> createMultiKeyCollector(long id, Collection<Address> primary,
         Map<Address, Collection<Integer>> backups, int topologyId) {
      if (backups.isEmpty()) {
         return new PrimaryOwnerOnlyCollector<>();
      }
      MultiKeyCollector collector = new MultiKeyCollector(id, backups, topologyId);
      collectorMap.put(id, collector);
      if (trace) {
         log.tracef("Created new collector for %s. Primary=%s. BackupSegments=%s", id, primary, backups);
      }
      return collector;
   }
public Collector < Map < Object , Object > > createMultiKeyCollector ( long id , Collection < Address > primary , Map < Address , Collection < Integer > > backups , int topologyId ) { if ( backups . isEmpty ( ) ) { return new PrimaryOwnerOnlyCollector < > ( ) ; } MultiKeyCollector collector = new MultiKeyCollector ( id , backups , topologyId ) ; collectorMap . put ( id , collector ) ; if ( trace ) { log . tracef ( "Created new collector for %s. Primary=%s. BackupSegments=%s" , id , primary , backups ) ; } return collector ; }
Creates a collector for {@link org.infinispan.commands.write.PutMapCommand}.
Creates a collector for { @link org . infinispan . commands . write . PutMapCommand } .