Package org.jumpmind.symmetric.service.impl

Class InitialLoadService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.InitialLoadService

All Implemented Interfaces:

IInitialLoadService, IService

public class InitialLoadService
extends AbstractService
implements IInitialLoadService

Field Summary

Fields

Modifier and Type	Field	Description
protected ISymmetricEngine	engine
protected IExtensionService	extensionService
protected int	lastLoadCountToProcess
protected final org.slf4j.Logger	log
protected boolean	syncTriggersBeforeInitialLoadAttempted

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

parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
InitialLoadService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
void	cancelAllLoadsForTarget(String targetNodeId)
void	cancelLoad(TableReloadStatus status)
protected List<NodeSecurity>	findNodesThatAreReadyForInitialLoad()
protected List<TriggerRouter>	getTriggerRoutersForNodeGroup(Map<String,List<TriggerRouter>> triggerRoutersByNodeGroup, String nodeGroupId)
protected boolean	isOkayToQueueLoad(NodeSecurity nodeSecurity)
protected boolean	isValidLoadTarget(String targetNodeId)
protected void	logActiveLoadCount(int activeLoadCount, int loadCountToProcess)
void	processInitialLoadEnabledFlag(Node identity, ProcessInfo processInfo)	If a load has been queued up by setting the initial load enabled or reverse initial load enabled flags, then the router service will insert the reload events.
protected void	processTableRequestLoads(Node source, ProcessInfo processInfo)
void	queueLoads(boolean force)
protected void	sendLoadBasedOnConfig(NodeSecurity security, boolean isReverse, ProcessInfo processInfo)

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

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, 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

Field Details

log

protected final org.slf4j.Logger log

engine

protected ISymmetricEngine engine

extensionService

protected IExtensionService extensionService

syncTriggersBeforeInitialLoadAttempted

protected boolean syncTriggersBeforeInitialLoadAttempted

lastLoadCountToProcess

protected int lastLoadCountToProcess

Constructor Details

InitialLoadService

public InitialLoadService(ISymmetricEngine engine)

Method Details

queueLoads

public void queueLoads(boolean force)

Specified by:

queueLoads in interface IInitialLoadService

cancelLoad

public void cancelLoad(TableReloadStatus status)

Specified by:

cancelLoad in interface IInitialLoadService

cancelAllLoadsForTarget

public void cancelAllLoadsForTarget(String targetNodeId)

Specified by:

cancelAllLoadsForTarget in interface IInitialLoadService

processInitialLoadEnabledFlag

public void processInitialLoadEnabledFlag(Node identity,
 ProcessInfo processInfo)

If a load has been queued up by setting the initial load enabled or reverse initial load enabled flags, then the router service will insert the reload events. This process will not run at the same time sync triggers is running.

sendLoadBasedOnConfig

protected void sendLoadBasedOnConfig(NodeSecurity security,
 boolean isReverse,
 ProcessInfo processInfo)

processTableRequestLoads

protected void processTableRequestLoads(Node source,
 ProcessInfo processInfo)

logActiveLoadCount

protected void logActiveLoadCount(int activeLoadCount,
 int loadCountToProcess)

getTriggerRoutersForNodeGroup

protected List<TriggerRouter> getTriggerRoutersForNodeGroup(Map<String,List<TriggerRouter>> triggerRoutersByNodeGroup,
 String nodeGroupId)

findNodesThatAreReadyForInitialLoad

protected List<NodeSecurity> findNodesThatAreReadyForInitialLoad()

isOkayToQueueLoad

protected boolean isOkayToQueueLoad(NodeSecurity nodeSecurity)

isValidLoadTarget

protected boolean isValidLoadTarget(String targetNodeId)