com.hazelcast.client.impl.protocol.task.map

Class AbstractMapPutMessageTask<P>

java.lang.Object

com.hazelcast.client.impl.protocol.task.AbstractMessageTask<P>

com.hazelcast.client.impl.protocol.task.AbstractPartitionMessageTask<P>

com.hazelcast.client.impl.protocol.task.map.AbstractMapPutMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, ExecutionCallback, PartitionSpecificRunnable, Runnable, Executor

Direct Known Subclasses:

MapPutIfAbsentMessageTask, MapPutMessageTask, MapPutTransientMessageTask, MapReplaceIfSameMessageTask, MapReplaceMessageTask, MapSetMessageTask, MapTryPutMessageTask

public abstract class AbstractMapPutMessageTask<P>
extends AbstractPartitionMessageTask<P>

Field Summary

Fields

Modifier and Type	Field and Description
protected long	startTimeNanos

Fields inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

clientEngine, clientMessage, connection, endpoint, endpointManager, logger, nodeEngine, parameters, serializationService

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMapPutMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
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.
protected MapOperationProvider	getMapOperationProvider(String mapName)
Permission	getRequiredPermission()
String	getServiceName()

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractPartitionMessageTask

afterResponse, execute, onFailure, onResponse, prepareOperation, processMessage

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

decodeClientMessage, encodeResponse, getClientVersion, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, handleProcessingFailure, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

startTimeNanos

protected transient long startTimeNanos

Constructor Detail

AbstractMapPutMessageTask

protected AbstractMapPutMessageTask(ClientMessage clientMessage,
                                    Node node,
                                    Connection connection)

Method Detail

beforeProcess

protected void beforeProcess()

Description copied from class: AbstractPartitionMessageTask

Called on node side, before starting any operation.

Overrides:

beforeProcess in class AbstractPartitionMessageTask<P>

beforeResponse

protected void beforeResponse()

Description copied from class: AbstractPartitionMessageTask

Called on node side, after process is run and right before sending the response to the client.

Overrides:

beforeResponse in class AbstractPartitionMessageTask<P>

getRequiredPermission

public Permission getRequiredPermission()

getServiceName

public String getServiceName()

Specified by:

getServiceName in class AbstractMessageTask<P>

getMapOperationProvider

protected final MapOperationProvider getMapOperationProvider(String mapName)