public abstract class AbstractPartitionMessageTask<P> extends AbstractMessageTask<P> implements ExecutionCallback
clientEngine, clientMessage, connection, endpoint, endpointManager, logger, nodeEngine, parameters, serializationService
Modifier | Constructor and Description |
---|---|
protected |
AbstractPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterResponse()
Called on node side, after sending the response to the client.
|
protected void |
beforeProcess()
Called on node side, before starting any operation.
|
protected void |
beforeResponse()
Called on node side, after process is run and right before sending the response to the client.
|
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 abstract Operation |
prepareOperation() |
void |
processMessage() |
decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMethodName, getParameters, getPartitionId, getService, getServiceName, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRequiredPermission
protected AbstractPartitionMessageTask(ClientMessage clientMessage, Node node, Connection connection)
protected void beforeProcess()
protected void beforeResponse()
protected void afterResponse()
public final void processMessage()
processMessage
in class AbstractMessageTask<P>
protected abstract Operation prepareOperation()
public void onResponse(Object response)
ExecutionCallback
onResponse
in interface ExecutionCallback
response
- the result of the successful executionpublic void onFailure(Throwable t)
ExecutionCallback
onFailure
in interface ExecutionCallback
t
- the exception that is thrownCopyright © 2016 Hazelcast, Inc.. All Rights Reserved.