org.jumpmind.symmetric.route

Class BshDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.BshDataRouter

All Implemented Interfaces:

org.jumpmind.extension.IBuiltInExtensionPoint, org.jumpmind.extension.IExtensionPoint, IDataRouter

public class BshDataRouter
extends AbstractDataRouter
implements org.jumpmind.extension.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 and Description
protected ISymmetricEngine	engine

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

log

Constructor Summary

Constructors

Constructor and Description
BshDataRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
protected void	bind(bsh.Interpreter interpreter, DataMetaData dataMetaData, java.util.Set<Node> nodes, java.util.Set<java.lang.String> targetNodes, java.util.Set<java.lang.String> boundVariableNames, boolean initialLoad)
protected void	bind(bsh.Interpreter interpreter, java.util.Set<java.lang.String> boundVariableNames, java.lang.String name, java.lang.Object value)
protected java.util.Set<java.lang.String>	eval(java.lang.Object value, java.util.Set<Node> nodes, java.util.Set<java.lang.String> targetNodes)
protected bsh.Interpreter	getInterpreter(SimpleRouterContext context)
java.util.Set<java.lang.String>	routeToNodes(SimpleRouterContext context, DataMetaData dataMetaData, java.util.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 Detail

engine

protected ISymmetricEngine engine

Constructor Detail

BshDataRouter

public BshDataRouter(ISymmetricEngine engine)

Method Detail

routeToNodes

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

Specified by:

routeToNodes in interface IDataRouter

getInterpreter

protected bsh.Interpreter getInterpreter(SimpleRouterContext context)

eval

protected java.util.Set<java.lang.String> eval(java.lang.Object value,
                                               java.util.Set<Node> nodes,
                                               java.util.Set<java.lang.String> targetNodes)

bind

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

Throws:

bsh.EvalError

bind

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

Throws:

bsh.EvalError