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:

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

protected

AbstractMultiTargetMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

protected abstract OperationFactory	createOperationFactory()
abstract Collection<Address>	getTargets()
protected void	processMessage()
protected abstract ClientMessage	reduce(Map<Address,Object> map)

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

AbstractMultiTargetMessageTask

protected AbstractMultiTargetMessageTask(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 ClientMessage reduce(Map<Address,Object> map)
                                 throws Throwable

Throws:

Throwable

getTargets

public abstract Collection<Address> getTargets()