org.jumpmind.symmetric.route

Class JavaDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.JavaDataRouter

All Implemented Interfaces:

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

public class JavaDataRouter
extends AbstractDataRouter
implements org.jumpmind.extension.IBuiltInExtensionPoint

This java data router is invoked when the router_type is 'java'. The router_expression is Java code for the routeToNodes() method of a class that extends the AbstractDataRouter. The class is compiled in memory and cached by both the context of the batch and the classloader. For a new batch, if the router_expression is the same, the same class is used, otherwise the class is renamed, compiled, and loaded again.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CODE_END
static java.lang.String	CODE_START
protected ISymmetricEngine	engine
protected java.lang.String	ROUTER_KEY

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

log

Constructor Summary

Constructors

Constructor and Description
JavaDataRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
protected IDataRouter	getCompiledClass(SimpleRouterContext context, Router router)
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

CODE_START

public static final java.lang.String CODE_START

See Also:

Constant Field Values

CODE_END

public static final java.lang.String CODE_END

See Also:

Constant Field Values

engine

protected ISymmetricEngine engine

ROUTER_KEY

protected final java.lang.String ROUTER_KEY

Constructor Detail

JavaDataRouter

public JavaDataRouter(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

getCompiledClass

protected IDataRouter getCompiledClass(SimpleRouterContext context,
                                       Router router)
                                throws java.lang.Exception

Throws:

java.lang.Exception