org.jumpmind.symmetric.route

Interface IDataRouter

All Superinterfaces:

org.jumpmind.extension.IExtensionPoint

All Known Implementing Classes:

AbstractDataRouter, AbstractFileParsingRouter, AuditTableDataRouter, BshDataRouter, ColumnMatchDataRouter, ConfigurationChangedDataRouter, ConvertToReloadRouter, CSVRouter, DBFRouter, DefaultDataRouter, FileSyncDataRouter, JavaDataRouter, LookupTableDataRouter, SubSelectDataRouter, TPSRouter

public interface IDataRouter
extends org.jumpmind.extension.IExtensionPoint

The data router is an extension point that allows the end user to target certain nodes with data changes. SymmetricDS comes with a build-in data routers like SubSelectDataRouter and ColumnMatchDataRouter.

In order to configure a data router you use the router_type and router_expression column on the trigger table. The given Spring bean name of the IDataRouter is the router_type and each data router is configured using the routing_expression according to its implementation.

Since:

2.0

See Also:

SubSelectDataRouter, ColumnMatchDataRouter

Method Summary

Modifier and Type	Method and Description
void	completeBatch(SimpleRouterContext context, OutgoingBatch batch)
void	contextCommitted(SimpleRouterContext context)
boolean	isConfigurable()
java.util.Set<java.lang.String>	routeToNodes(SimpleRouterContext context, DataMetaData dataMetaData, java.util.Set<Node> nodes, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter)

Method Detail

routeToNodes

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

completeBatch

void completeBatch(SimpleRouterContext context,
                   OutgoingBatch batch)

contextCommitted

void contextCommitted(SimpleRouterContext context)

isConfigurable

boolean isConfigurable()