com.hazelcast.client.impl.protocol.task.mapreduce
Class MapReduceJobProcessInformationMessageTask

java.lang.Object
  com.hazelcast.client.impl.protocol.task.AbstractMessageTask<P>
      com.hazelcast.client.impl.protocol.task.AbstractCallableMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>
          com.hazelcast.client.impl.protocol.task.mapreduce.MapReduceJobProcessInformationMessageTask

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

public class MapReduceJobProcessInformationMessageTask
extends AbstractCallableMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>

Field Summary

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

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

Constructor Summary

MapReduceJobProcessInformationMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

protected ClientMessage	call()
protected com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters	decodeClientMessage(ClientMessage clientMessage)
String	getDistributedObjectName() Used for SecurityInterceptor
String	getMethodName() Used for SecurityInterceptor Method name which called via a distributedObject for map.put, methodName will be 'put' For requests which do not produced via a distributedObject should return null, for example internal client.
Object[]	getParameters() Used for SecurityInterceptor Parameters passed to the method by a distributedObject for map.put(key, value) parameters should be 'key' and 'value' parameters can be in binary or object form, underlying implementation will de-serialize lazily
Permission	getRequiredPermission()
String	getServiceName()

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

processMessage

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

getDistributedObjectType, getEndpoint, getPartitionId, getService, run, sendClientMessage, sendClientMessage, sendClientMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

MapReduceJobProcessInformationMessageTask

public MapReduceJobProcessInformationMessageTask(ClientMessage clientMessage,
                                                 Node node,
                                                 Connection connection)

Method Detail

call

protected ClientMessage call()
                      throws Exception

Specified by:

call in class AbstractCallableMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>

Throws:

Exception

decodeClientMessage

protected com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters decodeClientMessage(ClientMessage clientMessage)

Specified by:

decodeClientMessage in class AbstractMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>

getServiceName

public String getServiceName()

Specified by:

getServiceName in class AbstractMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>

getRequiredPermission

public Permission getRequiredPermission()

getDistributedObjectName

public String getDistributedObjectName()

Description copied from interface: SecureRequest

Used for SecurityInterceptor

Specified by:

getDistributedObjectName in interface SecureRequest

Specified by:

getDistributedObjectName in class AbstractMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>

Returns:

getMethodName

public String getMethodName()

Description copied from interface: SecureRequest

Used for SecurityInterceptor Method name which called via a distributedObject for map.put, methodName will be 'put' For requests which do not produced via a distributedObject should return null, for example internal client.

Specified by:

getMethodName in interface SecureRequest

Specified by:

getMethodName in class AbstractMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>

Returns:

getParameters

public Object[] getParameters()

Description copied from interface: SecureRequest

Used for SecurityInterceptor Parameters passed to the method by a distributedObject for map.put(key, value) parameters should be 'key' and 'value' parameters can be in binary or object form, underlying implementation will de-serialize lazily

Specified by:

getParameters in interface SecureRequest

Specified by:

getParameters in class AbstractMessageTask<com.hazelcast.client.impl.protocol.parameters.MapReduceJobProcessInformationParameters>

Returns: