Package org.infinispan.xsite.irac

Class IracClearResponseCollector

java.lang.Object
org.infinispan.xsite.irac.IracClearResponseCollector
All Implemented Interfaces:
Runnable
public class IracClearResponseCollector extends Object implements Runnable
Used by asynchronous cross-site replication, it aggregates response from multiple sites and returns IracBatchSendResult.

This collector assumes the request is a ClearCommand, and never completes exceptionally.

Since:
14.0
Author:
Pedro Ruivo

  • Constructor Details

    • IracClearResponseCollector

      public IracClearResponseCollector(String cacheName)

  • Method Details

    • dependsOn

      public void dependsOn(IracXSiteBackup backup, CompletionStage<Void> request)

    • freeze

      public CompletionStage<org.infinispan.xsite.irac.IracBatchSendResult> freeze()

    • forceBackOffAndRetry

      public void forceBackOffAndRetry()

    • run

      public void run()
      Specified by:
      run in interface Runnable