Package org.jumpmind.symmetric.job

Class SqlJob

java.lang.Object

org.jumpmind.symmetric.job.AbstractJob

org.jumpmind.symmetric.job.SqlJob

All Implemented Interfaces:

Runnable, IExtensionPoint, IJob

public class SqlJob
extends AbstractJob

Field Summary

Fields inherited from class org.jumpmind.symmetric.job.AbstractJob

engine, jobName, log, parameterService, randomTimeSlot

Constructor Summary

Constructors

Constructor	Description
SqlJob(String jobName, ISymmetricEngine engine, org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler taskScheduler)

Method Summary

Modifier and Type	Method	Description
protected void	doJob(boolean force)
JobDefaults	getDefaults()
JobDefinition.JobType	getJobType()
protected Map<String,String>	getReplacementTokens(ISymmetricEngine engine, Map<String,String> startingReplacementTokens)

Methods inherited from class org.jumpmind.symmetric.job.AbstractJob

checkPrerequsites, getAverageExecutionTimeInMs, getDeprecatedStartParameter, getEngine, getJobDefinition, getJobName, getLastExecutionTimeInMs, getLastFinishTime, getName, getNextExecutionTime, getNumberOfRuns, getParameterService, getProcessedCount, getSchedule, getTargetNodeCount, getTargetNodeId, getTaskScheduler, getTimeBetweenRunsInMs, getTotalExecutionTimeInMs, invoke, invoke, isCronSchedule, isPaused, isPeriodicSchedule, isRunning, isStarted, pause, run, setEngine, setJobDefinition, setJobName, setParameterService, setPaused, setProcessedCount, setTargetNodeCount, setTargetNodeId, setTaskScheduler, setThreadPoolTaskScheduler, start, stop, unpause

Methods inherited from class java.lang.Object

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

Constructor Details

SqlJob

public SqlJob(String jobName,
 ISymmetricEngine engine,
 org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler taskScheduler)

Method Details

getJobType

public JobDefinition.JobType getJobType()

doJob

protected void doJob(boolean force)
              throws Exception

Specified by:

doJob in class AbstractJob

Throws:

Exception

getDefaults

public JobDefaults getDefaults()

Specified by:

getDefaults in class AbstractJob

getReplacementTokens

protected Map<String,String> getReplacementTokens(ISymmetricEngine engine,
 Map<String,String> startingReplacementTokens)