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, CacheRemoveAllKeysMessageTask, CacheRemoveAllMessageTask, CacheSizeMessageTask, MapAddIndexMessageTask, MapClearMessageTask, MapContainsValueMessageTask, MapEvictAllMessageTask, MapExecuteOnAllKeysMessageTask, MapExecuteWithPredicateMessageTask, MapIsEmptyMessageTask, MapLoadGivenKeysMessageTask, MapSizeMessageTask, MultiMapClearMessageTask, MultiMapContainsValueMessageTask, MultiMapEntrySetMessageTask, MultiMapKeySetMessageTask, MultiMapSizeMessageTask, MultiMapValuesMessageTask, ReplicatedMapClearMessageTask, ReplicatedMapPutAllMessageTask

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

Constructors

Constructor and Description
AbstractAllPartitionsMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract OperationFactory	createOperationFactory()
protected void	processMessage()
protected abstract Object	reduce(Map<Integer,Object> map)

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

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

AbstractAllPartitionsMessageTask

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

Method Detail

processMessage

protected void processMessage()
                       throws Exception

Specified by:

processMessage in class AbstractMessageTask<P>

Throws:

Exception

createOperationFactory

protected abstract OperationFactory createOperationFactory()

reduce

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