public abstract class AbstractPartitionMessageTask<P> extends AbstractMessageTask<P> implements Executor, PartitionSpecificRunnable, BiConsumer<Object,Throwable>
clientEngine, clientMessage, connection, endpoint, logger, nodeEngine, parameters, serializationService
Modifier | Constructor and Description |
---|---|
protected |
AbstractPartitionMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
accept(Object response,
Throwable throwable) |
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 |
execute(Runnable command) |
int |
getPartitionId()
Returns the partition ID.
|
protected abstract Operation |
prepareOperation() |
void |
processMessage() |
decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, peelIfNeeded, requiresAuthentication, run, sendClientMessage, sendClientMessage, sendResponse
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
andThen
getRequiredPermission
protected AbstractPartitionMessageTask(ClientMessage clientMessage, Node node, Connection connection)
protected void beforeProcess()
protected void beforeResponse()
protected void afterResponse()
public int getPartitionId()
PartitionSpecificRunnable
getPartitionId
in interface PartitionSpecificRunnable
public final void processMessage()
processMessage
in class AbstractMessageTask<P>
protected abstract Operation prepareOperation()
Copyright © 2019 Hazelcast, Inc.. All rights reserved.