org.jumpmind.symmetric.route

Class ConfigurationChangedDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.ConfigurationChangedDataRouter

All Implemented Interfaces:

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

public class ConfigurationChangedDataRouter
extends AbstractDataRouter
implements IDataRouter, org.jumpmind.extension.IBuiltInExtensionPoint

Field Summary

Fields

Modifier and Type	Field and Description
protected ISymmetricEngine	engine
static java.lang.String	KEY
static java.lang.String	ROUTER_TYPE

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

log

Constructor Summary

Constructors

Constructor and Description
ConfigurationChangedDataRouter()
ConfigurationChangedDataRouter(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
void	contextCommitted(SimpleRouterContext routingContext)
protected java.util.Set<Node>	filterOutNodesByDeploymentType(DataMetaData dataMetaData, java.util.Set<Node> possibleTargetNodes)
protected java.util.Set<Node>	filterOutOlderNodes(DataMetaData dataMetaData, java.util.Set<Node> possibleTargetNodes)
protected Node	findIdentity()
protected java.util.List<NodeGroupLink>	getNodeGroupLinksFromContext(SimpleRouterContext routingContext)
protected NetworkedNode	getRootNetworkNodeFromContext(SimpleRouterContext routingContext)
boolean	isConfigurable() Override if a router is not configurable.
protected void	queueSyncTriggers(SimpleRouterContext routingContext, DataMetaData dataMetaData, java.util.Map<java.lang.String,java.lang.String> columnValues)
protected void	routeNodeTables(java.util.Set<java.lang.String> nodeIds, java.util.Map<java.lang.String,java.lang.String> columnValues, NetworkedNode rootNetworkedNode, Node me, SimpleRouterContext routingContext, DataMetaData dataMetaData, java.util.Set<Node> possibleTargetNodes, boolean initialLoad)
protected void	routeSymNodeSecurity(Node me, java.lang.String nodeIdForRecordBeingRouted, DataMetaData dataMetaData, java.util.Set<java.lang.String> nodeIds, java.util.Map<java.lang.String,java.lang.String> columnValues)
java.util.Set<java.lang.String>	routeToNodes(SimpleRouterContext routingContext, DataMetaData dataMetaData, java.util.Set<Node> possibleTargetNodes, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter)

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.route.IDataRouter

completeBatch

Field Detail

ROUTER_TYPE

public static final java.lang.String ROUTER_TYPE

See Also:

Constant Field Values

KEY

public static final java.lang.String KEY

See Also:

Constant Field Values

engine

protected ISymmetricEngine engine

Constructor Detail

ConfigurationChangedDataRouter

public ConfigurationChangedDataRouter()

ConfigurationChangedDataRouter

public ConfigurationChangedDataRouter(ISymmetricEngine engine)

Method Detail

routeToNodes

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

Specified by:

routeToNodes in interface IDataRouter

filterOutNodesByDeploymentType

protected java.util.Set<Node> filterOutNodesByDeploymentType(DataMetaData dataMetaData,
                                                             java.util.Set<Node> possibleTargetNodes)

filterOutOlderNodes

protected java.util.Set<Node> filterOutOlderNodes(DataMetaData dataMetaData,
                                                  java.util.Set<Node> possibleTargetNodes)

routeNodeTables

protected void routeNodeTables(java.util.Set<java.lang.String> nodeIds,
                               java.util.Map<java.lang.String,java.lang.String> columnValues,
                               NetworkedNode rootNetworkedNode,
                               Node me,
                               SimpleRouterContext routingContext,
                               DataMetaData dataMetaData,
                               java.util.Set<Node> possibleTargetNodes,
                               boolean initialLoad)

routeSymNodeSecurity

protected void routeSymNodeSecurity(Node me,
                                    java.lang.String nodeIdForRecordBeingRouted,
                                    DataMetaData dataMetaData,
                                    java.util.Set<java.lang.String> nodeIds,
                                    java.util.Map<java.lang.String,java.lang.String> columnValues)

queueSyncTriggers

protected void queueSyncTriggers(SimpleRouterContext routingContext,
                                 DataMetaData dataMetaData,
                                 java.util.Map<java.lang.String,java.lang.String> columnValues)

findIdentity

protected Node findIdentity()

getNodeGroupLinksFromContext

protected java.util.List<NodeGroupLink> getNodeGroupLinksFromContext(SimpleRouterContext routingContext)

getRootNetworkNodeFromContext

protected NetworkedNode getRootNetworkNodeFromContext(SimpleRouterContext routingContext)

contextCommitted

public void contextCommitted(SimpleRouterContext routingContext)

Specified by:

contextCommitted in interface IDataRouter

Overrides:

contextCommitted in class AbstractDataRouter

isConfigurable

public boolean isConfigurable()

Description copied from class: AbstractDataRouter

Override if a router is not configurable.

Specified by:

isConfigurable in interface IDataRouter

Overrides:

isConfigurable in class AbstractDataRouter