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>>
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
ConstructorsConstructorDescriptionFilterMapResponseCollector
(ResponseFilter filter, boolean waitForAll, int expectedSize) -
Method Summary
Modifier and TypeMethodDescriptionaddException
(Address sender, Exception exception) Process an exception from a target.addTargetNotFound
(Address sender) Process a target leaving the cluster or stopping the cache.addValidResponse
(Address sender, ValidResponse response) Process a valid response from a target.finish()
Called afterResponseCollector.addResponse(Address, Response)
returnsnull
for the last response.Methods inherited from class org.infinispan.remoting.transport.ValidResponseCollector
addResponse
-
Constructor Details
-
FilterMapResponseCollector
-
-
Method Details
-
addValidResponse
Description copied from class:ValidResponseCollector
Process a valid response from a target.- Specified by:
addValidResponse
in classValidResponseCollector<Map<Address,
Response>> - Returns:
null
to continue waiting for response, non-null
to complete with that value.
-
addTargetNotFound
Description copied from class:ValidResponseCollector
Process a target leaving the cluster or stopping the cache.- Specified by:
addTargetNotFound
in classValidResponseCollector<Map<Address,
Response>> - Returns:
null
to continue waiting for response, non-null
to complete with that value.
-
addException
Description copied from class:ValidResponseCollector
Process an exception from a target.- Specified by:
addException
in classValidResponseCollector<Map<Address,
Response>> - Returns:
null
to continue waiting for responses (the default), non-null
to complete with that value.
-
finish
Description copied from interface:ResponseCollector
Called afterResponseCollector.addResponse(Address, Response)
returnsnull
for the last response.If
finish()
finishes normally, the request will complete with its return value (even ifnull
). Iffinish()
throws an exception, the request will complete exceptionally with that exception, wrapped in aCompletionException
(unless the exception is already aCompletionException
).- Specified by:
finish
in interfaceResponseCollector<Map<Address,
Response>> - Specified by:
finish
in classValidResponseCollector<Map<Address,
Response>>
-