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 returnsIracBatchSendResult
.This collector assumes the request is a
ClearCommand
.- Since:
- 14.0
- Author:
- Pedro Ruivo
-
-
Constructor Summary
Constructors Constructor Description IracClearResponseCollector(String cacheName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
dependsOn(IracXSiteBackup backup, CompletionStage<Void> request)
CompletionStage<org.infinispan.xsite.irac.IracBatchSendResult>
freeze()
void
run()
-
-
-
Constructor Detail
-
IracClearResponseCollector
public IracClearResponseCollector(String cacheName)
-
-
Method Detail
-
dependsOn
public void dependsOn(IracXSiteBackup backup, CompletionStage<Void> request)
-
freeze
public CompletionStage<org.infinispan.xsite.irac.IracBatchSendResult> freeze()
-
-