com.hazelcast.client.impl.protocol.task

Class AbstractCallableMessageTask<P>

java.lang.Object

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

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

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

AbstractMapAddEntryListenerMessageTask, AbstractMapQueryMessageTask, AbstractMultiMapAddEntryListenerMessageTask, AbstractRemoveListenerMessageTask, AbstractReplicatedMapAddEntryListenerMessageTask, AbstractTransactionalMessageTask, AddDistributedObjectListenerMessageTask, AddMembershipListenerMessageTask, AddPartitionListenerMessageTask, AddPartitionLostListenerMessageTask, CacheAddEntryListenerMessageTask, CacheAddNearCacheInvalidationListenerTask, CacheAddPartitionLostListenerMessageTask, ClientStatisticsMessageTask, DestroyProxyMessageTask, DurableExecutorIsShutdownMessageTask, DurableExecutorShutdownMessageTask, ExecutorServiceIsShutdownMessageTask, ExecutorServiceShutdownMessageTask, GetDistributedObjectsMessageTask, GetPartitionsMessageTask, IsFailoverSupportedMessageTask, ListAddListenerMessageTask, MapAddListenerMessageTask, MapAddPartitionLostListenerMessageTask, MapDestroyCacheMessageTask, MapExecuteWithPredicateMessageTask, MapFlushMessageTask, MapLoadAllMessageTask, MapPublisherCreateMessageTask, MapPublisherCreateWithValueMessageTask, MapReduceCancelMessageTask, MapReduceJobProcessInformationMessageTask, PingMessageTask, PNCounterGetConfiguredReplicaCountMessageTask, Pre38CacheAddInvalidationListenerTask, QueueAddListenerMessageTask, RemoveAllListenersMessageTask, SetAddListenerMessageTask, TopicAddMessageListenerMessageTask, XAClearRemoteTransactionMessageTask, XATransactionCommitMessageTask, XATransactionCreateMessageTask, XATransactionPrepareMessageTask, XATransactionRollbackMessageTask

public abstract class AbstractCallableMessageTask<P>
extends AbstractMessageTask<P>

Base callable Message task.

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	AbstractCallableMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
protected abstract Object	call()
void	processMessage()

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

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

AbstractCallableMessageTask

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

Method Detail

processMessage

public final void processMessage()
                          throws Exception

Specified by:

processMessage in class AbstractMessageTask<P>

Throws:

Exception

call

protected abstract Object call()
                        throws Exception

Throws:

Exception