net.thevpc.nuts.runtime.standalone.concurrent

Class NSagaCallableImpl<T>

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NSagaCallableImpl<T>

All Implemented Interfaces:

Callable<T>, net.thevpc.nuts.concurrent.NCallable<T>, net.thevpc.nuts.concurrent.NSagaCallable<T>, net.thevpc.nuts.elem.NDescribable, net.thevpc.nuts.elem.NRedescribable<net.thevpc.nuts.concurrent.NCallable<T>>, net.thevpc.nuts.util.NCopiable

public class NSagaCallableImpl<T>
extends Object
implements net.thevpc.nuts.concurrent.NSagaCallable<T>

Constructor Summary

Constructors

Constructor and Description
NSagaCallableImpl(net.thevpc.nuts.concurrent.NSagaModel model, net.thevpc.nuts.concurrent.NSagaStore store)

Method Summary

Modifier and Type	Method and Description
T	call()
T	callOrElse(net.thevpc.nuts.concurrent.NCallable<T> other)
net.thevpc.nuts.concurrent.NSagaCallable<T>	copy()
net.thevpc.nuts.concurrent.NSagaNodeModel	findById(String id)
<V> V	getVar(String key)
net.thevpc.nuts.concurrent.NSagaCallable<T>	newInstance()
net.thevpc.nuts.concurrent.NSagaCallable<T>	reset()
T	result()
boolean	runStep_children(String nodeId, List<net.thevpc.nuts.concurrent.NSagaNodeModel> list, int idx, String group)
boolean	runStep()
net.thevpc.nuts.concurrent.NSagaCallable<T>	setVar(String key, Object value)
net.thevpc.nuts.concurrent.NSagaStatus	status()

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.thevpc.nuts.concurrent.NCallable

of, withDescription

Methods inherited from interface net.thevpc.nuts.elem.NDescribable

describe

Constructor Detail

NSagaCallableImpl

public NSagaCallableImpl(net.thevpc.nuts.concurrent.NSagaModel model,
                         net.thevpc.nuts.concurrent.NSagaStore store)

Method Detail

reset

public net.thevpc.nuts.concurrent.NSagaCallable<T> reset()

Specified by:

reset in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

newInstance

public net.thevpc.nuts.concurrent.NSagaCallable<T> newInstance()

Specified by:

newInstance in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

status

public net.thevpc.nuts.concurrent.NSagaStatus status()

Specified by:

status in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

call

public T call()

Specified by:

call in interface Callable<T>

Specified by:

call in interface net.thevpc.nuts.concurrent.NCallable<T>

copy

public net.thevpc.nuts.concurrent.NSagaCallable<T> copy()

Specified by:

copy in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

Specified by:

copy in interface net.thevpc.nuts.util.NCopiable

runStep_children

public boolean runStep_children(String nodeId,
                                List<net.thevpc.nuts.concurrent.NSagaNodeModel> list,
                                int idx,
                                String group)

runStep

public boolean runStep()

Specified by:

runStep in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

findById

public net.thevpc.nuts.concurrent.NSagaNodeModel findById(String id)

callOrElse

public T callOrElse(net.thevpc.nuts.concurrent.NCallable<T> other)

Specified by:

callOrElse in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

getVar

public <V> V getVar(String key)

Specified by:

getVar in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

setVar

public net.thevpc.nuts.concurrent.NSagaCallable<T> setVar(String key,
                                                          Object value)

Specified by:

setVar in interface net.thevpc.nuts.concurrent.NSagaCallable<T>

result

public T result()

Specified by:

result in interface net.thevpc.nuts.concurrent.NSagaCallable<T>