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, ExecutionCallback<Map<Integer,Object>>, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

CacheAssignAndGetUuidsMessageTask, CacheClearMessageTask, CacheGetAllMessageTask, CacheLoadAllMessageTask, CacheRemoveAllKeysMessageTask, CacheRemoveAllMessageTask, CacheSizeMessageTask, MapAddIndexMessageTask, MapAssignAndGetUuidsMessageTask, MapClearMessageTask, MapContainsValueMessageTask, MapEvictAllMessageTask, MapExecuteOnAllKeysMessageTask, MapIsEmptyMessageTask, MapLoadGivenKeysMessageTask, MapMadePublishableMessageTask, MapRemoveAllMessageTask, MapSizeMessageTask, MultiMapClearMessageTask, MultiMapContainsValueMessageTask, MultiMapEntrySetMessageTask, MultiMapKeySetMessageTask, MultiMapSizeMessageTask, MultiMapValuesMessageTask, ReplicatedMapClearMessageTask, ReplicatedMapPutAllMessageTask

public abstract class AbstractAllPartitionsMessageTask<P>
extends AbstractMessageTask<P>
implements ExecutionCallback<Map<Integer,Object>>

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected abstract OperationFactory	createOperationFactory()
void	onFailure(Throwable throwable) Called when an execution is completed with an error.
void	onResponse(Map<Integer,Object> map) Called when an execution is completed successfully.
protected void	processMessage()
protected abstract Object	reduce(Map<Integer,Object> map)

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

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

Specified by:

processMessage in class AbstractMessageTask<P>

createOperationFactory

protected abstract OperationFactory createOperationFactory()

reduce

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

onFailure

public final void onFailure(Throwable throwable)

Description copied from interface: ExecutionCallback

Called when an execution is completed with an error.

Specified by:

onFailure in interface ExecutionCallback<Map<Integer,Object>>

Parameters:

throwable - the exception that is thrown

onResponse

public final void onResponse(Map<Integer,Object> map)

Description copied from interface: ExecutionCallback

Called when an execution is completed successfully.

Specified by:

onResponse in interface ExecutionCallback<Map<Integer,Object>>

Parameters:

map - the result of the successful execution