public abstract class AbstractAddressMessageTask<P> extends AbstractMessageTask<P> implements BiConsumer<Object,Throwable>, Executor
clientEngine, clientMessage, connection, endpoint, logger, nodeEngine, parameters, serializationService
Modifier | Constructor and Description |
---|---|
protected |
AbstractAddressMessageTask(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) |
protected abstract Address |
getAddress() |
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 AbstractAddressMessageTask(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 Address getAddress()
protected abstract Operation prepareOperation()
Copyright © 2019 Hazelcast, Inc.. All rights reserved.