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:

AbstractExecutorServiceCancelMessageTask, AbstractMapAddEntryListenerMessageTask, AbstractMapQueryMessageTask, AbstractMapReduceTask, AbstractMultiMapAddEntryListenerMessageTask, AbstractMultiPartitionMessageTask, AbstractReplicatedMapAddEntryListenerMessageTask, AbstractTransactionalMessageTask, AddDistributedObjectListenerMessageTask, AddPartitionLostListenerMessageTask, AuthenticationBaseMessageTask, CacheAddEntryListenerMessageTask, CacheAddInvalidationListenerTask, CacheRemoveEntryListenerMessageTask, CacheRemoveInvalidationListenerMessageTask, CreateProxyMessageTask, DestroyProxyMessageTask, ExecutorServiceIsShutdownMessageTask, ExecutorServiceShutdownMessageTask, GetDistributedObjectMessageTask, GetPartitionsMessageTask, ListAddListenerMessageTask, ListRemoveListenerMessageTask, MapAddPartitionLostListenerMessageTask, MapLoadAllMessageTask, MapReduceCancelMessageTask, MapReduceJobProcessInformationMessageTask, MapRemoveEntryListenerMessageTask, MapRemovePartitionLostListenerMessageTask, MultiMapRemoveEntryListenerMessageTask, PingMessageTask, QueueAddListenerMessageTask, QueueRemoveListenerMessageTask, RegisterMembershipListenerMessageTask, RemoveAllListenersMessageTask, RemoveDistrubtedObjectListenerMessageTask, RemovePartitionLostListenerMessageTask, ReplicatedMapClearMessageTask, ReplicatedMapContainsKeyMessageTask, ReplicatedMapContainsValueMessageTask, ReplicatedMapEntrySetMessageTask, ReplicatedMapGetMessageTask, ReplicatedMapIsEmptyMessageTask, ReplicatedMapKeySetMessageTask, ReplicatedMapPutAllMessageTask, ReplicatedMapPutMessageTask, ReplicatedMapRemoveEntryListenerMessageTask, ReplicatedMapRemoveMessageTask, ReplicatedMapSizeMessageTask, ReplicatedMapValuesMessageTask, SetAddListenerMessageTask, SetRemoveListenerMessageTask, TopicAddMessageListenerMessageTask, TopicRemoveMessageListenerMessageTask, 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, endpointManager, logger, nodeEngine, parameters, serializationService

Constructor Summary

protected

AbstractCallableMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

protected abstract ClientMessage	call()
void	processMessage()

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

decodeClientMessage, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMethodName, getParameters, getPartitionId, getService, getServiceName, run, sendClientMessage, sendClientMessage, sendClientMessage

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()

Specified by:

processMessage in class AbstractMessageTask<P>

call

protected abstract ClientMessage call()
                               throws Exception

Throws:

Exception