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 and Description
protected ISymmetricEngine	engine
protected IExtensionService	extensionService
protected int	lastLoadCountToProcess
protected 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 and Description
InitialLoadService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
void	cancelLoad(TableReloadStatus status)
protected java.util.List<NodeSecurity>	findNodesThatAreReadyForInitialLoad()
protected java.util.List<TriggerRouter>	getTriggerRoutersForNodeGroup(java.util.Map<java.lang.String,java.util.List<TriggerRouter>> triggerRoutersByNodeGroup, java.lang.String nodeGroupId)
protected boolean	isValidLoadTarget(java.lang.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)

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

Field Detail

log

protected final org.slf4j.Logger log

engine

protected ISymmetricEngine engine

extensionService

protected IExtensionService extensionService

syncTriggersBeforeInitialLoadAttempted

protected boolean syncTriggersBeforeInitialLoadAttempted

lastLoadCountToProcess

protected int lastLoadCountToProcess

Constructor Detail

InitialLoadService

public InitialLoadService(ISymmetricEngine engine)

Method Detail

queueLoads

public void queueLoads(boolean force)

Specified by:

queueLoads in interface IInitialLoadService

cancelLoad

public void cancelLoad(TableReloadStatus status)

Specified by:

cancelLoad 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.

processTableRequestLoads

protected void processTableRequestLoads(Node source,
                                        ProcessInfo processInfo)

logActiveLoadCount

protected void logActiveLoadCount(int activeLoadCount,
                                  int loadCountToProcess)

getTriggerRoutersForNodeGroup

protected java.util.List<TriggerRouter> getTriggerRoutersForNodeGroup(java.util.Map<java.lang.String,java.util.List<TriggerRouter>> triggerRoutersByNodeGroup,
                                                                      java.lang.String nodeGroupId)

findNodesThatAreReadyForInitialLoad

protected java.util.List<NodeSecurity> findNodesThatAreReadyForInitialLoad()

isValidLoadTarget

protected boolean isValidLoadTarget(java.lang.String targetNodeId)