public class RuleSetExec extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.util.Comparator<RuleResult> |
DEFAULT_PLAN_COMPARATOR |
static int |
DEFAULT_TIMEOUT |
static int |
MAX_CONCURRENT_PLANNERS |
Constructor and Description |
---|
RuleSetExec(TraceWriter traceWriter,
FlowPlanner flowPlanner,
Flow flow,
RuleRegistrySet registrySet,
FlowDef flowDef,
FlowElementGraph flowElementGraph) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
binResult(RuleResult ruleResult) |
protected java.util.concurrent.Callable<RuleResult> |
createCallable(RuleRegistry ruleRegistry) |
protected java.util.List<java.util.concurrent.Callable<RuleResult>> |
createCallables() |
RuleResult |
exec() |
protected RuleResult |
execPlannerFor(RuleRegistry ruleRegistry) |
protected ProcessLogger |
getFlowLogger() |
protected java.util.Comparator<RuleResult> |
getOrderComparator() |
protected java.util.Comparator<RuleResult> |
getPlanComparator() |
protected java.util.Set<java.util.concurrent.Future<RuleResult>> |
submitCallables(java.util.List<java.util.concurrent.Callable<RuleResult>> callables) |
public static final int MAX_CONCURRENT_PLANNERS
public static final int DEFAULT_TIMEOUT
public static final java.util.Comparator<RuleResult> DEFAULT_PLAN_COMPARATOR
public RuleSetExec(TraceWriter traceWriter, FlowPlanner flowPlanner, Flow flow, RuleRegistrySet registrySet, FlowDef flowDef, FlowElementGraph flowElementGraph)
protected ProcessLogger getFlowLogger()
protected java.util.Comparator<RuleResult> getPlanComparator()
protected java.util.Comparator<RuleResult> getOrderComparator()
public RuleResult exec()
protected RuleResult execPlannerFor(RuleRegistry ruleRegistry)
protected java.util.Set<java.util.concurrent.Future<RuleResult>> submitCallables(java.util.List<java.util.concurrent.Callable<RuleResult>> callables)
protected java.util.List<java.util.concurrent.Callable<RuleResult>> createCallables()
protected java.util.concurrent.Callable<RuleResult> createCallable(RuleRegistry ruleRegistry)
protected boolean binResult(RuleResult ruleResult)
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.