com.hazelcast.client.impl.client

Class PartitionClientRequest

java.lang.Object

com.hazelcast.client.impl.protocol.util.MessageFlyweight

com.hazelcast.client.impl.protocol.ClientMessage

com.hazelcast.client.impl.client.ClientRequest

com.hazelcast.client.impl.client.PartitionClientRequest

All Implemented Interfaces:

SecureRequest, ExecutionCallback, Portable, VersionedPortable, SocketReadable, SocketWritable

Direct Known Subclasses:

AbstractAlterRequest, AbstractAlterRequest, AtomicLongRequest, CacheIterateRequest, CollectionRequest, FinalizeXATransactionRequest, KeyBasedClientRequest, ModifyRequest, MultiMapRequest, PublishRequest, QueueRequest, ReadRequest, ReadRequest, SemaphoreRequest

public abstract class PartitionClientRequest
extends ClientRequest
implements ExecutionCallback

Base class for partition based client request.

Field Summary

Fields inherited from class com.hazelcast.client.impl.client.ClientRequest

callId, clientEngine, endpoint, operationService, serializationService, service

Fields inherited from class com.hazelcast.client.impl.protocol.ClientMessage

BEGIN_AND_END_FLAGS, BEGIN_FLAG, END_FLAG, HEADER_SIZE, LISTENER_EVENT_FLAG, VERSION

Fields inherited from class com.hazelcast.client.impl.protocol.util.MessageFlyweight

buffer

Constructor Summary

Constructors

Constructor and Description
PartitionClientRequest()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterResponse() Called on node side, after sending the response to the client.
protected void	beforeProcess() Called on node side, before starting any operation.
protected void	beforeResponse() Called on node side, after process is run and right before sending the response to the client.
protected Object	filter(Object response)
protected abstract int	getPartition()
protected int	getReplicaIndex()
void	onFailure(Throwable t) Called when an execution is completed with an error.
void	onResponse(Object object) Called when an execution is completed successfully.
protected abstract Operation	prepareOperation()
void	process()

Methods inherited from class com.hazelcast.client.impl.client.ClientRequest

getCallId, getClassVersion, getClientEngine, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMethodName, getParameters, getService, getServiceName, read, readPortable, setCallId, setClientEngine, setEndpoint, setOperationService, setSerializationService, setService, write, writePortable

Methods inherited from class com.hazelcast.client.impl.protocol.ClientMessage

addFlag, create, createForDecode, createForEncode, createForEncode, getCorrelationId, getDataOffset, getFlags, getFrameLength, getMessageType, getPartitionId, getVersion, isComplete, isFlagSet, isRetryable, isUrgent, readFrom, setCorrelationId, setDataOffset, setFrameLength, setMessageType, setPartitionId, setRetryable, setVersion, toString, updateFrameLength, wrapForDecode, wrapForEncode, writeTo

Methods inherited from class com.hazelcast.client.impl.protocol.util.MessageFlyweight

buffer, getBoolean, getByteArray, getData, getDataList, getDataSet, getInt, getLong, getStringUtf8, index, index, int32Get, int32Set, set, set, set, set, set, set, set, uint16Get, uint16Put, uint32Get, uint32Put, uint8Get, uint8Put, wrap

Methods inherited from class java.lang.Object

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

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

getRequiredPermission

Methods inherited from interface com.hazelcast.nio.serialization.Portable

getClassId, getFactoryId

Constructor Detail

PartitionClientRequest

public PartitionClientRequest()

Method Detail

beforeProcess

protected void beforeProcess()

Called on node side, before starting any operation.

beforeResponse

protected void beforeResponse()

Called on node side, after process is run and right before sending the response to the client.

afterResponse

protected void afterResponse()

Called on node side, after sending the response to the client.

process

public final void process()

Specified by:

process in class ClientRequest

prepareOperation

protected abstract Operation prepareOperation()

getPartition

protected abstract int getPartition()

getReplicaIndex

protected int getReplicaIndex()

filter

protected Object filter(Object response)

onResponse

public final void onResponse(Object object)

Description copied from interface: ExecutionCallback

Called when an execution is completed successfully.

Specified by:

onResponse in interface ExecutionCallback

Parameters:

object - the result of the successful execution

onFailure

public final void onFailure(Throwable t)

Description copied from interface: ExecutionCallback

Called when an execution is completed with an error.

Specified by:

onFailure in interface ExecutionCallback

Parameters:

t - the exception that is thrown