Package org.jumpmind.symmetric.route

Class BshDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.BshDataRouter

All Implemented Interfaces:

IBuiltInExtensionPoint, IExtensionPoint, IDataRouter

public class BshDataRouter
extends AbstractDataRouter
implements IBuiltInExtensionPoint

This data router is invoked when the router_type is 'bsh'. The router_expression is always a bean shell expression. See the bean shell site for information about the capabilities of the bean shell scripting language.

Bound to the interpreter are the names of both the current and old column values. They can be used in the expression. They should always be referenced using upper case. Also bound to the interpreter is a Collection of targetNodes. The script is expected to add the the list of target nodes a list of the node_ids that should be routed to.

Field Summary

Fields

Modifier and Type	Field	Description
protected ISymmetricEngine	engine

Fields inherited from class org.jumpmind.symmetric.route.AbstractDataRouter

log

Constructor Summary

Constructors

Constructor	Description
BshDataRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected void	bind(bsh.Interpreter interpreter, Set<String> boundVariableNames, String name, Object value)
protected void	bind(bsh.Interpreter interpreter, DataMetaData dataMetaData, Set<Node> nodes, Set<String> targetNodes, Set<String> boundVariableNames, boolean initialLoad)
protected Set<String>	eval(Object value, Set<Node> nodes, Set<String> targetNodes)
protected bsh.Interpreter	getInterpreter(SimpleRouterContext context)
boolean	isDmlOnly()	Override if a router is able to route non-DML DataEventTypes.
Set<String>	routeToNodes(SimpleRouterContext context, DataMetaData dataMetaData, Set<Node> nodes, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter)

Methods inherited from class org.jumpmind.symmetric.route.AbstractDataRouter

addNodeId, completeBatch, contextCommitted, getDataAsObject, getDataAsString, getDataMap, getDataObjectMap, getNewDataAsObject, getNewDataAsString, getNullData, getOldDataAsObject, getOldDataAsString, getPkDataAsObject, getPkDataAsString, isConfigurable, testColumnNamesMatchValues, toExternalIds, toNodeIds

Methods inherited from class java.lang.Object

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

Field Details

engine

protected ISymmetricEngine engine

Constructor Details

BshDataRouter

public BshDataRouter(ISymmetricEngine engine)

Method Details

routeToNodes

public Set<String> routeToNodes(SimpleRouterContext context,
 DataMetaData dataMetaData,
 Set<Node> nodes,
 boolean initialLoad,
 boolean initialLoadSelectUsed,
 TriggerRouter triggerRouter)

Specified by:

routeToNodes in interface IDataRouter

getInterpreter

protected bsh.Interpreter getInterpreter(SimpleRouterContext context)

eval

protected Set<String> eval(Object value,
 Set<Node> nodes,
 Set<String> targetNodes)

bind

protected void bind(bsh.Interpreter interpreter,
 DataMetaData dataMetaData,
 Set<Node> nodes,
 Set<String> targetNodes,
 Set<String> boundVariableNames,
 boolean initialLoad)
             throws bsh.EvalError

Throws:

bsh.EvalError

bind

protected void bind(bsh.Interpreter interpreter,
 Set<String> boundVariableNames,
 String name,
 Object value)
             throws bsh.EvalError

Throws:

bsh.EvalError

isDmlOnly

public boolean isDmlOnly()

Description copied from class: AbstractDataRouter

Override if a router is able to route non-DML DataEventTypes.

Specified by:

isDmlOnly in interface IDataRouter

Overrides:

isDmlOnly in class AbstractDataRouter