public abstract class AbstractAllPartitionsMessageTask<P> extends AbstractMessageTask<P> implements ExecutionCallback<Map<Integer,Object>>
clientEngine, clientMessage, connection, endpoint, logger, nodeEngine, parameters, serializationService
Constructor and Description |
---|
AbstractAllPartitionsMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected abstract OperationFactory |
createOperationFactory() |
void |
onFailure(Throwable throwable)
Called when an execution is completed with an error.
|
void |
onResponse(Map<Integer,Object> map)
Called when an execution is completed successfully.
|
protected void |
processMessage() |
protected abstract Object |
reduce(Map<Integer,Object> map) |
decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, requiresAuthentication, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRequiredPermission
public AbstractAllPartitionsMessageTask(ClientMessage clientMessage, Node node, Connection connection)
protected void processMessage()
processMessage
in class AbstractMessageTask<P>
protected abstract OperationFactory createOperationFactory()
public final void onFailure(Throwable throwable)
ExecutionCallback
onFailure
in interface ExecutionCallback<Map<Integer,Object>>
throwable
- the exception that is thrownpublic final void onResponse(Map<Integer,Object> map)
ExecutionCallback
onResponse
in interface ExecutionCallback<Map<Integer,Object>>
map
- the result of the successful executionCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.