com.hazelcast.client.impl.protocol.task
Class AbstractAllPartitionsMessageTask<P>

java.lang.Object
  com.hazelcast.client.impl.protocol.task.AbstractMessageTask<P>
      com.hazelcast.client.impl.protocol.task.AbstractAllPartitionsMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

CacheClearMessageTask, CacheGetAllMessageTask, CacheLoadAllMessageTask, CacheRemoveAllMessageTask, CacheSizeMessageTask, MapAddIndexMessageTask, MapClearMessageTask, MapContainsValueMessageTask, MapEntrySetMessageTask, MapEvictAllMessageTask, MapExecuteOnAllKeysMessageTask, MapExecuteWithPredicateMessageTask, MapFlushMessageTask, MapGetAllMessageTask, MapIsEmptyMessageTask, MapKeySetMessageTask, MapLoadGivenKeysMessageTask, MapPutAllMessageTask, MapSizeMessageTask, MapValuesMessageTask, MultiMapClearMessageTask, MultiMapContainsValueMessageTask, MultiMapEntrySetMessageTask, MultiMapKeySetMessageTask, MultiMapSizeMessageTask, MultiMapValuesMessageTask

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

Field Summary

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

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

Constructor Summary

AbstractAllPartitionsMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

protected abstract OperationFactory	createOperationFactory()
protected void	processMessage()
protected abstract ClientMessage	reduce(Map<Integer,Object> map)

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

AbstractAllPartitionsMessageTask

public AbstractAllPartitionsMessageTask(ClientMessage clientMessage,
                                        Node node,
                                        Connection connection)

Method Detail

processMessage

protected void processMessage()

Specified by:

processMessage in class AbstractMessageTask<P>

createOperationFactory

protected abstract OperationFactory createOperationFactory()

reduce

protected abstract ClientMessage reduce(Map<Integer,Object> map)