com.hazelcast.client.impl.protocol.task

Class AbstractMultiTargetMessageTask<P>

java.lang.Object

com.hazelcast.client.impl.protocol.task.AbstractMessageTask<P>

com.hazelcast.client.impl.protocol.task.AbstractMultiTargetMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

AuthenticationBaseMessageTask, DeployClassesMessageTask, MapAddInterceptorMessageTask, MapRemoveInterceptorMessageTask, XACollectTransactionsMessageTask

public abstract class AbstractMultiTargetMessageTask<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

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

Method Summary

Modifier and Type	Method and Description
protected abstract Supplier<Operation>	createOperationSupplier()
abstract Collection<Member>	getTargets()
protected void	processMessage()
protected abstract Object	reduce(Map<Member,Object> map)

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

decodeClientMessage, encodeResponse, getClientVersion, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMemberBuildInfo, 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

AbstractMultiTargetMessageTask

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

Method Detail

processMessage

protected void processMessage()
                       throws Throwable

Specified by:

processMessage in class AbstractMessageTask<P>

Throws:

Throwable

createOperationSupplier

protected abstract Supplier<Operation> createOperationSupplier()

reduce

protected abstract Object reduce(Map<Member,Object> map)
                          throws Throwable

Throws:

Throwable

getTargets

public abstract Collection<Member> getTargets()