Package org.infinispan.xsite.response

Class AutoStateTransferResponseCollector

java.lang.Object

org.infinispan.xsite.response.AutoStateTransferResponseCollector

All Implemented Interfaces:

ResponseCollector<AutoStateTransferResponse>

public class AutoStateTransferResponseCollector
extends Object
implements ResponseCollector<AutoStateTransferResponse>

A ResponseCollector that merges AutoStateTransferResponse.

Since:

12.1

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
AutoStateTransferResponseCollector(boolean isOffline, XSiteStateTransferMode stateTransferMode)

Method Summary

Modifier and Type	Method	Description
AutoStateTransferResponse	addResponse(Address sender, Response response)	Called when a response is received, or when a target node becomes unavailable.
AutoStateTransferResponse	finish()	Called after ResponseCollector.addResponse(Address, Response) returns null for the last response.
void	merge(AutoStateTransferResponse response)

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoStateTransferResponseCollector

public AutoStateTransferResponseCollector(boolean isOffline,
                                          XSiteStateTransferMode stateTransferMode)

Method Detail

finish

public AutoStateTransferResponse finish()

Description copied from interface: ResponseCollector

Called after ResponseCollector.addResponse(Address, Response) returns null for the last response.

If finish() finishes normally, the request will complete with its return value (even if null). If finish() throws an exception, the request will complete exceptionally with that exception, wrapped in a CompletionException (unless the exception is already a CompletionException).

Specified by:

finish in interface ResponseCollector<AutoStateTransferResponse>

addResponse

public final AutoStateTransferResponse addResponse(Address sender,
                                                   Response response)

Description copied from interface: ResponseCollector

Called when a response is received, or when a target node becomes unavailable.

When a target node leaves the cluster, this method is called with a CacheNotFoundResponse.

Should return a non-null result if the request should complete with that value, or null if it should wait for more responses. If the method throws an exception, the request will be completed with that exception. If the last response is received and addResponse() still returns null, ResponseCollector.finish() will also be called to obtain a result.

Thread safety: addResponse() will *not* be called concurrently from multiple threads, and the request will not be completed while addResponse() is running.

Specified by:

addResponse in interface ResponseCollector<AutoStateTransferResponse>

merge

public void merge(AutoStateTransferResponse response)