com.hazelcast.cp.internal.client

Class AbstractCPMessageTask<P>

java.lang.Object

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

com.hazelcast.cp.internal.client.AbstractCPMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, ExecutionCallback<Object>, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

AcquirePermitsMessageTask, AddAndGetMessageTask, AlterMessageTask, ApplyMessageTask, ApplyMessageTask, AvailablePermitsMessageTask, AwaitMessageTask, ChangePermitsMessageTask, CloseSessionMessageTask, CompareAndSetMessageTask, CompareAndSetMessageTask, ContainsMessageTask, CountDownMessageTask, CreateSessionMessageTask, DestroyRaftObjectMessageTask, DrainPermitsMessageTask, GenerateThreadIdMessageTask, GetAndAddMessageTask, GetAndSetMessageTask, GetCountMessageTask, GetLockOwnershipStateMessageTask, GetMessageTask, GetMessageTask, GetRoundMessageTask, HeartbeatSessionMessageTask, InitSemaphoreMessageTask, LockMessageTask, ReleasePermitsMessageTask, SetMessageTask, TryLockMessageTask, TrySetCountMessageTask, UnlockMessageTask

public abstract class AbstractCPMessageTask<P>
extends AbstractMessageTask<P>
implements ExecutionCallback<Object>

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	invoke(CPGroupId groupId, RaftOp op)
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	query(CPGroupId groupId, RaftOp op, QueryPolicy policy)

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

decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, processMessage, requiresAuthentication, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.client.impl.client.SecureRequest

getRequiredPermission

Constructor Detail

AbstractCPMessageTask

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

Method Detail

query

protected void query(CPGroupId groupId,
                     RaftOp op,
                     QueryPolicy policy)

invoke

protected void invoke(CPGroupId groupId,
                      RaftOp op)

onResponse

public void onResponse(Object response)

Description copied from interface: ExecutionCallback

Called when an execution is completed successfully.

Specified by:

onResponse in interface ExecutionCallback<Object>

Parameters:

response - the result of the successful execution

onFailure

public void onFailure(Throwable t)

Description copied from interface: ExecutionCallback

Called when an execution is completed with an error.

Specified by:

onFailure in interface ExecutionCallback<Object>

Parameters:

t - the exception that is thrown