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.AbstractMultiPartitionMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, Runnable, BiConsumer<Map<Integer,Object>,Throwable>

Direct Known Subclasses:

MapExecuteOnKeysMessageTask

public abstract class AbstractMultiPartitionMessageTask<P>
extends AbstractMessageTask<P>
implements BiConsumer<Map<Integer,Object>,Throwable>

Field Summary

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

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMultiPartitionMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
void	accept(Map<Integer,Object> map, Throwable throwable)
protected abstract OperationFactory	createOperationFactory()
abstract PartitionIdSet	getPartitions()
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, getMemberBuildInfo, getMethodName, getParameters, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, peelIfNeeded, requiresAuthentication, run, 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 java.util.function.BiConsumer

andThen

Methods inherited from interface com.hazelcast.client.impl.client.SecureRequest

getRequiredPermission

Constructor Detail

AbstractMultiPartitionMessageTask

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

Method Detail

processMessage

protected void processMessage()

Specified by:

processMessage in class AbstractMessageTask<P>

getPartitions

public abstract PartitionIdSet getPartitions()

createOperationFactory

protected abstract OperationFactory createOperationFactory()

reduce

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

accept

public void accept(Map<Integer,Object> map,
                   Throwable throwable)

Specified by:

accept in interface BiConsumer<Map<Integer,Object>,Throwable>