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

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

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

MapExecuteOnKeysMessageTask

public abstract class AbstractMultiPartitionMessageTask<P>
extends AbstractCallableMessageTask<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

protected

AbstractMultiPartitionMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

protected ClientMessage	call()
protected abstract OperationFactory	createOperationFactory()
abstract Collection<Integer>	getPartitions()
protected abstract ClientMessage	reduce(Map<Integer,Object> map)

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

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

AbstractMultiPartitionMessageTask

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

Method Detail

call

protected ClientMessage call()
                      throws Exception

Specified by:

call in class AbstractCallableMessageTask<P>

Throws:

Exception

createOperationFactory

protected abstract OperationFactory createOperationFactory()

reduce

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

getPartitions

public abstract Collection<Integer> getPartitions()