com.hazelcast.client.impl.protocol.task.map

Class AbstractMapQueryMessageTask<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.map.AbstractMapQueryMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

MapEntriesWithPagingPredicateMessageTask, MapEntriesWithPredicateMessageTask, MapKeySetWithPagingPredicateMessageTask, MapKeySetWithPredicateMessageTask, MapValuesWithPagingPredicateMessageTask, MapValuesWithPredicateMessageTask

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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected Object	call()
protected abstract Predicate	getPredicate()
Permission	getRequiredPermission()
String	getServiceName()
protected abstract Object	reduce(Collection<QueryResultEntry> result)

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

processMessage

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

decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMethodName, getParameters, getPartitionId, getService, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractMapQueryMessageTask

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

Method Detail

getServiceName

public final String getServiceName()

Specified by:

getServiceName in class AbstractMessageTask<P>

getRequiredPermission

public Permission getRequiredPermission()

call

protected final Object call()
                     throws Exception

Specified by:

call in class AbstractCallableMessageTask<P>

Throws:

Exception

getPredicate

protected abstract Predicate getPredicate()

reduce

protected abstract Object reduce(Collection<QueryResultEntry> result)