com.hazelcast.client.impl.protocol.task

Class AbstractTransactionalMessageTask<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.AbstractTransactionalMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

TransactionalListAddMessageTask, TransactionalListRemoveMessageTask, TransactionalListSizeMessageTask, TransactionalMapContainsKeyMessageTask, TransactionalMapDeleteMessageTask, TransactionalMapGetForUpdateMessageTask, TransactionalMapGetMessageTask, TransactionalMapIsEmptyMessageTask, TransactionalMapKeySetMessageTask, TransactionalMapKeySetWithPredicateMessageTask, TransactionalMapPutIfAbsentMessageTask, TransactionalMapPutMessageTask, TransactionalMapRemoveIfSameMessageTask, TransactionalMapRemoveMessageTask, TransactionalMapReplaceIfSameMessageTask, TransactionalMapReplaceMessageTask, TransactionalMapSetMessageTask, TransactionalMapSizeMessageTask, TransactionalMapValuesMessageTask, TransactionalMapValuesWithPredicateMessageTask, TransactionalMultiMapGetMessageTask, TransactionalMultiMapPutMessageTask, TransactionalMultiMapRemoveEntryMessageTask, TransactionalMultiMapRemoveMessageTask, TransactionalMultiMapSizeMessageTask, TransactionalMultiMapValueCountMessageTask, TransactionalQueueOfferMessageTask, TransactionalQueuePeekMessageTask, TransactionalQueuePollMessageTask, TransactionalQueueSizeMessageTask, TransactionalQueueTakeMessageTask, TransactionalSetAddMessageTask, TransactionalSetRemoveMessageTask, TransactionalSetSizeMessageTask, TransactionCommitMessageTask, TransactionCreateMessageTask, TransactionRollbackMessageTask

public abstract class AbstractTransactionalMessageTask<P>
extends AbstractCallableMessageTask<P>

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
AbstractTransactionalMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
protected Object	call()
protected abstract long	getClientThreadId()
protected abstract Object	innerCall()

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

processMessage

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

decodeClientMessage, doRun, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, getServiceName, handleProcessingFailure, 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

AbstractTransactionalMessageTask

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

Method Detail

call

protected final Object call()
                     throws Exception

Specified by:

call in class AbstractCallableMessageTask<P>

Throws:

Exception

innerCall

protected abstract Object innerCall()
                             throws Exception

Throws:

Exception

getClientThreadId

protected abstract long getClientThreadId()