com.hazelcast.client.impl.protocol.task

Class AbstractInvocationMessageTask<P>

java.lang.Object

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

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

All Implemented Interfaces:

SecureRequest, MessageTask, Runnable, BiConsumer<Object,Throwable>

Direct Known Subclasses:

CacheDestroyMessageTask, CacheFetchNearCacheInvalidationMetadataTask, CacheListenerRegistrationMessageTask, CacheManagementConfigMessageTask, CreateProxyMessageTask, ExecutorServiceSubmitToAddressMessageTask, MapFetchNearCacheInvalidationMetadataTask, ReadMetricsMessageTask, ScheduledExecutorShutdownMessageTask

public abstract class AbstractInvocationMessageTask<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	AbstractInvocationMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
void	accept(Object response, Throwable throwable)
protected abstract InvocationBuilder	getInvocationBuilder(Operation op)
protected abstract Operation	prepareOperation()
protected void	processMessage()

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

decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, peelIfNeeded, 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

AbstractInvocationMessageTask

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

Method Detail

processMessage

protected void processMessage()

Specified by:

processMessage in class AbstractMessageTask<P>

accept

public void accept(Object response,
                   Throwable throwable)

Specified by:

accept in interface BiConsumer<Object,Throwable>

getInvocationBuilder

protected abstract InvocationBuilder getInvocationBuilder(Operation op)

prepareOperation

protected abstract Operation prepareOperation()