Package org.jumpmind.symmetric.route

Class JavaDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.JavaDataRouter

All Implemented Interfaces:

IBuiltInExtensionPoint, IExtensionPoint, IDataRouter

public class JavaDataRouter
extends AbstractDataRouter
implements 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	Description
static final String	CODE_END
static final String	CODE_START
protected ISymmetricDialect	dialect
protected ISymmetricEngine	engine
protected final String	ROUTER_KEY

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

log

Constructor Summary

Constructors

Constructor	Description
JavaDataRouter(ISymmetricEngine engine)

Method Summary

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

CODE_START

public static final String CODE_START

See Also:

• Constant Field Values

CODE_END

public static final String CODE_END

See Also:

• Constant Field Values

engine

protected ISymmetricEngine engine

dialect

protected ISymmetricDialect dialect

ROUTER_KEY

protected final String ROUTER_KEY

Constructor Details

JavaDataRouter

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

getCompiledClass

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

Throws:

Exception

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