code.data.IFlowOrchestration

Aliases

Parameters

subClasses

superClasses

Any

code.data.Exceptor

code.data.HasLogSource

java.lang.Object

Js Constructors

new code_data_IFlowOrchestration(
    orchestrator, // code.data.FlowOrchestrator
    recipe, // code.data.Recipe
    streamProcessors, // scala.collection.immutable.Map[code.data.StreamProcessor[code.data.Datumcode.data.Datum]java.lang.String]
    startingPayload, // scala.Option[code.data.Payload[code.data.Datum]]
    overrideLogLevel, // scala.Option[code.data.ConsoleFilter]
    startingParent, // scala.Option[code.data.IFlowOrchestration]
    shutdownPayloadOnCompletion, // boolean
    incomingDeferTermination, // boolean
    startingTerminationListeners, // scala.Function1[code.data.IFlowOrchestrationscala.collection.immutable.List[code.data.TerminationListener]]
    configContext, // scala.Option[code.data.ConfigurationContext]
)

ApplyMethods

Methods

$bang$eq(x$1:Any):boolean

$eq$eq(x$1:Any):boolean

$hash$hash():int

$init$():Unit

addTerminationListener(t:code.data.TerminationListener):Unit

asInstanceOf():scala.Any.T0

configContext():scala.Option[code.data.ConfigurationContext]

deferTermination():Unit

eq(x$1:java.lang.Object):boolean

equals(x$1:Any):boolean

getClass():java.lang.Class[Any]

getExecutionStrategy():code.data.executionStrategy.ExecutionStrategy

getFinalPayload(timeout:scala.concurrent.duration.Duration):scala.util.Either[java.lang.Exceptionscala.Option[code.data.Payload[code.data.Datum]]]

getIdentity():code.data.OrchestrationIdentity

getKillingException():scala.Option[java.lang.Exception]

getLogLevel():code.data.ConsoleFilter

getMemory():code.data.FlowOrchestrationMemory

getNextStep():scala.Option[code.data.StreamProcessor[code.data.Datumcode.data.Datum]]

getPayload():scala.Option[code.data.Payload[code.data.Datum]]

getPayloadFinalizer():scala.Option[scala.Function0[Unit]]

getState():scala.Enumeration$Value

getStepNumber():int

hashCode():int

id():java.lang.String

isInstanceOf():boolean

isRunning():boolean

kill(exception:java.lang.Exception):Unit

kill$default$1():java.lang.Exception

logSource():scala.Some[code.data.LogSource]

ne(x$1:java.lang.Object):boolean

notify():Unit

notifyAll():Unit

orchestrator():code.data.FlowOrchestrator

pause():Unit

recipe():code.data.Recipe

repo():code.data.IFlowRepository

resume():Unit

setOnNotifyFlowStatus(pf:scala.Option[scala.Function1[Unitcode.data.FlowStatus]]):Unit

setOnPayloadChanged(pf:scala.Option[scala.Function1[Unitcode.data.Payload[code.data.Datum]]]):Unit

setParent(p:scala.Option[code.data.IFlowOrchestration]):Unit

setParent$default$1():scala.Option[code.data.IFlowOrchestration]

synchronized(x$1:java.lang.Object.T0):java.lang.Object.T0

toString():java.lang.String

triggerTime():long

wait():Unit

wait(x$1:long):Unit

wait(x$1:long, x$2:int):Unit