Package org.infinispan.remoting.transport.impl

Class MapResponseCollector

java.lang.Object

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

org.infinispan.remoting.transport.impl.MapResponseCollector

All Implemented Interfaces:

ResponseCollector<Map<Address,Response>>

@Experimental
public abstract class MapResponseCollector
extends ValidResponseCollector<Map<Address,Response>>

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

Since:

9.2

Author:

Dan Berindei

Field Summary

Fields

Modifier and Type	Field	Description
protected final HashMap<Address,Response>	map

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>	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.
static MapResponseCollector	ignoreLeavers()
static MapResponseCollector	ignoreLeavers(boolean ignoreLeavers)
static MapResponseCollector	ignoreLeavers(boolean ignoreLeavers, int expectedSize)
static MapResponseCollector	ignoreLeavers(int expectedSize)
protected void	recordException(Exception e)
static MapResponseCollector	validOnly()
static MapResponseCollector	validOnly(int expectedSize)

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

addResponse, addTargetNotFound

Methods inherited from class java.lang.Object

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

Field Details

map

protected final HashMap<Address,Response> map

Method Details

validOnly

public static MapResponseCollector validOnly(int expectedSize)

validOnly

public static MapResponseCollector validOnly()

ignoreLeavers

public static MapResponseCollector ignoreLeavers(int expectedSize)

ignoreLeavers

public static MapResponseCollector ignoreLeavers()

ignoreLeavers

public static MapResponseCollector ignoreLeavers(boolean ignoreLeavers,
 int expectedSize)

ignoreLeavers

public static MapResponseCollector ignoreLeavers(boolean ignoreLeavers)

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.

recordException

protected void recordException(Exception e)

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.

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