public abstract class AbstractOnePhaseTask extends Object implements IMVCCTask<AbstractMVCCProtocolTaskResult>
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_TRANSACTION_LEASE |
Modifier | Constructor and Description |
---|---|
protected |
AbstractOnePhaseTask(MVCCGenerationsState generationsState,
int taskRetries,
long retryIntervalMillis) |
Modifier and Type | Method and Description |
---|---|
protected abstract AbstractMVCCProtocolTaskResult |
createFailedTaskResult(Throwable e) |
AbstractMVCCProtocolTaskResult |
execute()
Computes a result, or throws an exception if unable to do so.
|
protected abstract AbstractMVCCProtocolTaskResult |
executeTask(IDirectSpaceProxy proxy,
Transaction transaction) |
long |
getActiveGeneration() |
IDirectSpaceProxy |
getDirectSpaceProxy() |
protected AbstractOnePhaseTask(MVCCGenerationsState generationsState, int taskRetries, long retryIntervalMillis)
public AbstractMVCCProtocolTaskResult execute() throws Exception
Task
execute
in interface Task<AbstractMVCCProtocolTaskResult>
Exception
- if unable to compute a resultpublic long getActiveGeneration()
getActiveGeneration
in interface IMVCCTask<AbstractMVCCProtocolTaskResult>
protected abstract AbstractMVCCProtocolTaskResult executeTask(IDirectSpaceProxy proxy, Transaction transaction) throws Exception
Exception
protected abstract AbstractMVCCProtocolTaskResult createFailedTaskResult(Throwable e)
public IDirectSpaceProxy getDirectSpaceProxy()
Copyright © GigaSpaces.