public abstract class AbstractStableClusterMessageTask<P> extends AbstractMessageTask<P> implements ExecutionCallback
clientEngine, clientMessage, connection, endpoint, logger, nodeEngine, parameters, serializationService
Modifier | Constructor and Description |
---|---|
protected |
AbstractStableClusterMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
onFailure(Throwable t)
Called when an execution is completed with an error.
|
void |
onResponse(Object response)
Called when an execution is completed successfully.
|
protected void |
processMessage() |
protected abstract Object |
resolve(Object response) |
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
protected AbstractStableClusterMessageTask(ClientMessage clientMessage, Node node, Connection connection)
protected void processMessage() throws Throwable
processMessage
in class AbstractMessageTask<P>
Throwable
public final void onResponse(Object response)
ExecutionCallback
onResponse
in interface ExecutionCallback
response
- the result of the successful executionpublic final void onFailure(Throwable t)
ExecutionCallback
onFailure
in interface ExecutionCallback
t
- the exception that is thrownCopyright © 2021 Hazelcast, Inc.. All Rights Reserved.