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, Runnable, BiConsumer<Object,Throwable>

Direct Known Subclasses:

AcquirePermitsMessageTask, AddAndGetMessageTask, AlterMessageTask, ApplyMessageTask, ApplyMessageTask, AvailablePermitsMessageTask, AwaitMessageTask, ChangePermitsMessageTask, CloseSessionMessageTask, CompareAndSetMessageTask, CompareAndSetMessageTask, ContainsMessageTask, CountDownMessageTask, CreateRaftGroupMessageTask, 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 BiConsumer<Object,Throwable>

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
void	accept(Object response, Throwable throwable)

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

decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, peelIfNeeded, processMessage, requiresAuthentication, run, 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 java.util.function.BiConsumer

andThen

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

getRequiredPermission

Constructor Detail

AbstractCPMessageTask

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

Method Detail

accept

public void accept(Object response,
                   Throwable throwable)

Specified by:

accept in interface BiConsumer<Object,Throwable>