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.

Since:

14.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
IracClearResponseCollector(String cacheName)

Method Summary

Modifier and Type	Method	Description
void	dependsOn(IracXSiteBackup backup, CompletionStage<Void> request)
CompletionStage<org.infinispan.xsite.irac.IracBatchSendResult>	freeze()
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()

run

public void run()

Specified by:

run in interface Runnable