org.jumpmind.symmetric.service.impl

Class RouterService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.RouterService

All Implemented Interfaces:

IRouterService, IService

public class RouterService
extends AbstractService
implements IRouterService

See Also:

IRouterService

Field Summary

Fields

Modifier and Type	Field and Description
protected long	commonBatchesCacheTime
protected java.util.Map<java.lang.String,java.lang.Boolean>	commonBatchesLastKnownState
protected java.util.Map<java.lang.String,java.lang.Boolean>	defaultRouterOnlyLastKnownState
protected long	defaultRoutersCacheTime
protected ISymmetricEngine	engine
protected IExtensionService	extensionService
protected boolean	firstTimeCheck
protected DataGapDetector	gapDetector
protected boolean	hasMaxDataRoutedOnChannel
protected java.util.Map<java.lang.String,CounterStat>	invalidRouterType
protected java.util.Map<java.lang.Integer,CounterStat>	missingTriggerRouter
protected java.util.concurrent.ExecutorService	readThread
protected long	triggerRouterCacheTime

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor and Description
RouterService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
protected org.jumpmind.db.model.Table	buildTableFromTriggerHistory(TriggerHistory triggerHistory)
protected void	completeBatches(ChannelRouterContext context, java.util.List<OutgoingBatch> batches, java.util.Set<IDataRouter> usedRouters)
protected void	completeBatchesAndCommit(ChannelRouterContext context)
protected java.util.Set<Node>	findAvailableNodes(TriggerRouter triggerRouter, ChannelRouterContext context)
java.util.List<java.lang.String>	getAvailableBatchAlgorithms() Get a list of available batch algorithms that can be used for the different channels
java.util.List<DataGap>	getDataGaps()
protected IDataRouter	getDataRouter(Router router)
protected java.util.Set<java.lang.String>	getReadyChannels()
java.util.Map<java.lang.String,IDataRouter>	getRouters()
protected java.util.List<TriggerRouter>	getTriggerRoutersForData(Data data)
long	getUnroutedDataCount()
protected int	insertDataEvents(ProcessInfo processInfo, ChannelRouterContext context, DataMetaData dataMetaData, java.util.Collection<java.lang.String> nodeIds)
protected boolean	onlyDefaultRoutersAssigned(Channel channel, java.lang.String nodeGroupId, java.util.List<TriggerRouter> triggerRouters)
protected boolean	producesCommonBatches(Channel channel, java.lang.String nodeGroupId, java.util.List<TriggerRouter> triggerRouters) Deprecated.
protected java.lang.String	qualifyUsingDataGaps(java.util.List<DataGap> dataGaps, int numberOfGapsToQualify, java.lang.String sql)
long	routeData(boolean force) This method will route data to specific nodes.
protected int	routeData(ProcessInfo processInfo, Data data, ChannelRouterContext context)
protected long	routeDataForChannel(ProcessInfo processInfo, NodeChannel nodeChannel, Node sourceNode, boolean isOverrideContainsBigLob, java.util.Map<java.lang.String,OutgoingBatch> overrideBatchesByNodes, java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,OutgoingBatch>> overrideBatchesByGroups)
protected long	routeDataForEachChannel() We route data channel by channel for two reasons.
protected long	selectDataAndRoute(ProcessInfo processInfo, ChannelRouterContext context) Pre-read data and fill up a queue so we can peek ahead to see if we have crossed a database transaction boundary.
boolean	shouldDataBeRouted(SimpleRouterContext context, DataMetaData dataMetaData, Node node, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter) For use in data load events
protected IDataToRouteReader	startReading(ChannelRouterContext context)
void	stop()

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, 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.service.IService

getSql, synchronize

Field Detail

missingTriggerRouter

protected java.util.Map<java.lang.Integer,CounterStat> missingTriggerRouter

invalidRouterType

protected java.util.Map<java.lang.String,CounterStat> invalidRouterType

triggerRouterCacheTime

protected long triggerRouterCacheTime

commonBatchesLastKnownState

protected java.util.Map<java.lang.String,java.lang.Boolean> commonBatchesLastKnownState

commonBatchesCacheTime

protected long commonBatchesCacheTime

defaultRouterOnlyLastKnownState

protected java.util.Map<java.lang.String,java.lang.Boolean> defaultRouterOnlyLastKnownState

defaultRoutersCacheTime

protected long defaultRoutersCacheTime

readThread

protected transient java.util.concurrent.ExecutorService readThread

engine

protected ISymmetricEngine engine

extensionService

protected IExtensionService extensionService

gapDetector

protected DataGapDetector gapDetector

firstTimeCheck

protected boolean firstTimeCheck

hasMaxDataRoutedOnChannel

protected boolean hasMaxDataRoutedOnChannel

Constructor Detail

RouterService

public RouterService(ISymmetricEngine engine)

Method Detail

shouldDataBeRouted

public boolean shouldDataBeRouted(SimpleRouterContext context,
                                  DataMetaData dataMetaData,
                                  Node node,
                                  boolean initialLoad,
                                  boolean initialLoadSelectUsed,
                                  TriggerRouter triggerRouter)

For use in data load events

Specified by:

shouldDataBeRouted in interface IRouterService

stop

public void stop()

Specified by:

stop in interface IRouterService

routeData

public long routeData(boolean force)

This method will route data to specific nodes.

Specified by:

routeData in interface IRouterService

routeDataForEachChannel

protected long routeDataForEachChannel()

We route data channel by channel for two reasons. One is that if/when we decide to multi-thread the routing it is a simple matter of inserting a thread pool here and waiting for all channels to be processed. The other reason is to reduce the number of connections we are required to have.

getReadyChannels

protected java.util.Set<java.lang.String> getReadyChannels()

qualifyUsingDataGaps

protected java.lang.String qualifyUsingDataGaps(java.util.List<DataGap> dataGaps,
                                                int numberOfGapsToQualify,
                                                java.lang.String sql)

producesCommonBatches

@Deprecated
protected boolean producesCommonBatches(Channel channel,
                                                    java.lang.String nodeGroupId,
                                                    java.util.List<TriggerRouter> triggerRouters)

Deprecated.

onlyDefaultRoutersAssigned

protected boolean onlyDefaultRoutersAssigned(Channel channel,
                                             java.lang.String nodeGroupId,
                                             java.util.List<TriggerRouter> triggerRouters)

routeDataForChannel

protected long routeDataForChannel(ProcessInfo processInfo,
                                   NodeChannel nodeChannel,
                                   Node sourceNode,
                                   boolean isOverrideContainsBigLob,
                                   java.util.Map<java.lang.String,OutgoingBatch> overrideBatchesByNodes,
                                   java.util.Map<java.lang.Integer,java.util.Map<java.lang.String,OutgoingBatch>> overrideBatchesByGroups)

completeBatchesAndCommit

protected void completeBatchesAndCommit(ChannelRouterContext context)

completeBatches

protected void completeBatches(ChannelRouterContext context,
                               java.util.List<OutgoingBatch> batches,
                               java.util.Set<IDataRouter> usedRouters)

findAvailableNodes

protected java.util.Set<Node> findAvailableNodes(TriggerRouter triggerRouter,
                                                 ChannelRouterContext context)

startReading

protected IDataToRouteReader startReading(ChannelRouterContext context)

selectDataAndRoute

protected long selectDataAndRoute(ProcessInfo processInfo,
                                  ChannelRouterContext context)
                           throws java.lang.InterruptedException

Pre-read data and fill up a queue so we can peek ahead to see if we have crossed a database transaction boundary. Then route each Data while continuing to keep the queue filled until the result set is entirely read.

Parameters:

conn - The connection to use for selecting the data.

context - The current context of the routing process

Throws:

java.lang.InterruptedException

routeData

protected int routeData(ProcessInfo processInfo,
                        Data data,
                        ChannelRouterContext context)

insertDataEvents

protected int insertDataEvents(ProcessInfo processInfo,
                               ChannelRouterContext context,
                               DataMetaData dataMetaData,
                               java.util.Collection<java.lang.String> nodeIds)

getDataRouter

protected IDataRouter getDataRouter(Router router)

getTriggerRoutersForData

protected java.util.List<TriggerRouter> getTriggerRoutersForData(Data data)

getUnroutedDataCount

public long getUnroutedDataCount()

Specified by:

getUnroutedDataCount in interface IRouterService

getAvailableBatchAlgorithms

public java.util.List<java.lang.String> getAvailableBatchAlgorithms()

Description copied from interface: IRouterService

Get a list of available batch algorithms that can be used for the different channels

Specified by:

getAvailableBatchAlgorithms in interface IRouterService

getRouters

public java.util.Map<java.lang.String,IDataRouter> getRouters()

Specified by:

getRouters in interface IRouterService

getDataGaps

public java.util.List<DataGap> getDataGaps()

Specified by:

getDataGaps in interface IRouterService

buildTableFromTriggerHistory

protected org.jumpmind.db.model.Table buildTableFromTriggerHistory(TriggerHistory triggerHistory)