org.infinispan.remoting.transport.impl

Class FilterMapResponseCollector

java.lang.Object

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

org.infinispan.remoting.transport.impl.FilterMapResponseCollector

All Implemented Interfaces:

ResponseCollector<Map<Address,Response>>

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

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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(Address, Response) returns null for the last response.

Methods inherited from class org.infinispan.remoting.transport.ValidResponseCollector

addResponse

Methods inherited from class java.lang.Object

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

Constructor Detail

FilterMapResponseCollector

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

Method Detail

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(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<Map<Address,Response>>

Specified by:

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