Class InternalDurableTaskWrapper<T extends Serializable, R>

java.lang.Object

org.openspaces.core.executor.internal.InternalSpaceTaskWrapper<T>

org.openspaces.core.executor.internal.InternalDistributedSpaceTaskWrapper<T,R>

org.openspaces.core.executor.internal.InternalDurableTaskWrapper<T,R>

All Implemented Interfaces:

AsyncResultFilter<T>, AsyncResultsReducer<T,R>, ContextSettable, DistributedSpaceTask<T,R>, DurableTask, SpaceTask<T>, SpaceTaskWrapper, SmartExternalizable, Externalizable, Serializable

public class InternalDurableTaskWrapper<T extends Serializable, R>
extends InternalDistributedSpaceTaskWrapper<T,R>
implements DurableTask, ContextSettable

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface AsyncResultFilter

AsyncResultFilter.Decision

Constructor Summary

Constructors

Constructor	Description
InternalDurableTaskWrapper()
InternalDurableTaskWrapper(DurableTask<T,R> task)

Method Summary

Modifier and Type	Method	Description
boolean	cancel()
T	execute(IJSpace space, Transaction tx)
void	setExecutionContext(Object context)

Methods inherited from class InternalDistributedSpaceTaskWrapper

onResult, readExternal, reduce, writeExternal

Methods inherited from class InternalSpaceTaskWrapper

getRouting, getSupportCodeChangeAnnotationContainer, getTask, getWrappedTask, setRouting

Methods inherited from class Object

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

Methods inherited from interface SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

InternalDurableTaskWrapper

public InternalDurableTaskWrapper()

InternalDurableTaskWrapper

public InternalDurableTaskWrapper(DurableTask<T,R> task)

Method Details

setExecutionContext

public void setExecutionContext(Object context)

Specified by:

setExecutionContext in interface ContextSettable

execute

public T execute(IJSpace space,
 Transaction tx)
          throws Exception

Specified by:

execute in interface SpaceTask<T extends Serializable>

Overrides:

execute in class InternalSpaceTaskWrapper<T extends Serializable>

Throws:

Exception

cancel

public boolean cancel()
               throws Exception

Specified by:

cancel in interface DurableTask

Throws:

Exception