Package org.jumpmind.symmetric.job

Class JobManager

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.job.JobManager

All Implemented Interfaces:

IJobManager, IService

public class JobManager
extends AbstractService
implements IJobManager

Field Summary

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

parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
JobManager(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
void	destroy()
List<JobDefinition>	getCustomJobDefinitions()
IJob	getJob(String name)
List<IJob>	getJobs()
void	init()
protected boolean	isAutoStartConfigured(IJob job)
boolean	isJobApplicableToNodeGroup(IJob job)
boolean	isStarted()
void	removeAllJobs()
void	removeJob(String name)
void	renameJob(String oldName, JobDefinition job)
void	restartJob(String name)
void	restartJobs()
void	saveJob(JobDefinition job)
void	saveJobAsCopy(JobDefinition job)
protected List<IJob>	sortJobs(List<IJob> jobs)
void	startJobs()
void	stopJobs()

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

Constructor Details

JobManager

public JobManager(ISymmetricEngine engine)

Method Details

init

public void init()

Specified by:

init in interface IJobManager

getCustomJobDefinitions

public List<JobDefinition> getCustomJobDefinitions()

Specified by:

getCustomJobDefinitions in interface IJobManager

isStarted

public boolean isStarted()

Specified by:

isStarted in interface IJobManager

getJob

public IJob getJob(String name)

Specified by:

getJob in interface IJobManager

startJobs

public void startJobs()

Specified by:

startJobs in interface IJobManager

isJobApplicableToNodeGroup

public boolean isJobApplicableToNodeGroup(IJob job)

Specified by:

isJobApplicableToNodeGroup in interface IJobManager

isAutoStartConfigured

protected boolean isAutoStartConfigured(IJob job)

stopJobs

public void stopJobs()

Specified by:

stopJobs in interface IJobManager

destroy

public void destroy()

Specified by:

destroy in interface IJobManager

getJobs

public List<IJob> getJobs()

Specified by:

getJobs in interface IJobManager

sortJobs

protected List<IJob> sortJobs(List<IJob> jobs)

restartJobs

public void restartJobs()

Specified by:

restartJobs in interface IJobManager

restartJob

public void restartJob(String name)

Specified by:

restartJob in interface IJobManager

saveJob

public void saveJob(JobDefinition job)

Specified by:

saveJob in interface IJobManager

saveJobAsCopy

public void saveJobAsCopy(JobDefinition job)

Specified by:

saveJobAsCopy in interface IJobManager

renameJob

public void renameJob(String oldName,
 JobDefinition job)

Specified by:

renameJob in interface IJobManager

removeJob

public void removeJob(String name)

Specified by:

removeJob in interface IJobManager

removeAllJobs

public void removeAllJobs()

Specified by:

removeAllJobs in interface IJobManager