trait RuntimeConfiguration extends AnyRef
The runtime configuration for pipeline execution.
This object provides configuration information to the pipeline execution engine.
- Alphabetic
- By Inheritance
- RuntimeConfiguration
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
expressionEvaluator: ExpressionEvaluator
Returns the expression evaluator.
Returns the expression evaluator.
An com.jafpl.runtime.ExpressionEvaluator is required to evaluate expressions for variable bindings and the when branches of a choose.
- returns
The evaluator.
-
abstract
def
traceEnabled(trace: String): Boolean
Enable trace events.
Enable trace events.
The actors that run steps will emit log messages if the appropriate traces are enabled. This method is called to determine if a particular trace is enabled.
- trace
A trace event.
- returns
True, if that event should be considered enabled.
-
abstract
def
watchdogTimeout: Long
The watchdog timeout.
The watchdog timeout.
Pipelines are a message passing, data flow system. Progress only occurs when steps are producing and consuming items. If no messages are sent for a period of
watchdogTimeoutmilliseconds, the pipeline will be treated as "hung" and terminated.In practice, this exists to help debug the execution engine. (Implementation bugs can cause pipelines to hang.)
Disable the watchdog timer by returning 0.
When the com.jafpl.runtime.GraphRuntime is waiting for a pipeline
Just Another Fine Pipeline Language
This is a pipeline framework. It’s built on top of Akka actors to support arbitrary data flow pipelines. It is wholly agnostic to the kinds of data that flow through the pipelines and the implementations of the steps that process them.
See http://jafpl.com/ for more general information.