Class FilterMapResponseCollector

java.lang.Object

org.infinispan.remoting.transport.ValidResponseCollector<Map<Address,Response>>

org.infinispan.remoting.transport.impl.FilterMapResponseCollector

All Implemented Interfaces:

ResponseCollector<Address, Map<Address,Response>>

public class FilterMapResponseCollector
extends ValidResponseCollector<Map<Address,Response>>

Response collector supporting JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).

This class is not thread-safe by itself. It expects an AbstractRequest to handle synchronization.

Constructor Summary

Constructors

Constructor	Description
FilterMapResponseCollector(ResponseFilter filter, boolean waitForAll, int expectedSize)

Method Summary

Modifier and Type	Method	Description
protected Map<Address,Response>	addException(Address sender, Exception exception)	Process an exception from a target.
protected Map<Address,Response>	addTargetNotFound(Address sender)	Process a target leaving the cluster or stopping the cache.
protected Map<Address,Response>	addValidResponse(Address sender, ValidResponse<?> response)	Process a valid response from a target.
Map<Address,Response>	finish()	Called after ResponseCollector.addResponse(S, Response) returns null for the last response.

Methods inherited from class ValidResponseCollector

addResponse

Methods inherited from class Object

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

Constructor Details

FilterMapResponseCollector

public FilterMapResponseCollector(ResponseFilter filter,
 boolean waitForAll,
 int expectedSize)

Method Details

addValidResponse

protected Map<Address,Response> addValidResponse(Address sender,
 ValidResponse<?> response)

Description copied from class: ValidResponseCollector

Process a valid response from a target.

Specified by:

addValidResponse in class ValidResponseCollector<Map<Address,Response>>

Returns:

null to continue waiting for response, non-null to complete with that value.

addTargetNotFound

protected Map<Address,Response> addTargetNotFound(Address sender)

Description copied from class: ValidResponseCollector

Process a target leaving the cluster or stopping the cache.

Specified by:

addTargetNotFound in class ValidResponseCollector<Map<Address,Response>>

Returns:

null to continue waiting for response, non-null to complete with that value.

addException

protected Map<Address,Response> addException(Address sender,
 Exception exception)

Description copied from class: ValidResponseCollector

Process an exception from a target.

Specified by:

addException in class ValidResponseCollector<Map<Address,Response>>

Returns:

null to continue waiting for responses (the default), non-null to complete with that value.

finish

public Map<Address,Response> finish()

Description copied from interface: ResponseCollector

Called after ResponseCollector.addResponse(S, 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<Address, Map<Address,Response>>

Specified by:

finish in class ValidResponseCollector<Map<Address,Response>>