org.springframework.batch.core.repository.support
Class AbstractJobRepositoryFactoryBean

java.lang.Object
  org.springframework.batch.core.repository.support.AbstractJobRepositoryFactoryBean

All Implemented Interfaces:

FactoryBean, InitializingBean

Direct Known Subclasses:

JobRepositoryFactoryBean, MapJobRepositoryFactoryBean

public abstract class AbstractJobRepositoryFactoryBean
extends Object
implements FactoryBean, InitializingBean

A FactoryBean that automates the creation of a SimpleJobRepository. Declares abstract methods for providing DAO object implementations.

Author:

Ben Hale, Lucas Ward, Robert Kasanicky

See Also:

JobRepositoryFactoryBean, MapJobRepositoryFactoryBean

Constructor Summary

AbstractJobRepositoryFactoryBean()

Method Summary

void	afterPropertiesSet()
protected abstract ExecutionContextDao	createExecutionContextDao()
protected abstract JobExecutionDao	createJobExecutionDao()
protected abstract JobInstanceDao	createJobInstanceDao()
protected abstract StepExecutionDao	createStepExecutionDao()
JobRepository	getJobRepository() Convenience method for clients to grab the JobRepository without a cast.
Object	getObject()
Class<JobRepository>	getObjectType() The type of object to be returned from getObject().
PlatformTransactionManager	getTransactionManager() The transaction manager used in this factory.
boolean	isSingleton()
void	setIsolationLevelForCreate(String isolationLevelForCreate) public setter for the isolation level to be used for the transaction when job execution entities are initially created.
void	setTransactionManager(PlatformTransactionManager transactionManager) Public setter for the PlatformTransactionManager.
void	setValidateTransactionState(boolean validateTransactionState) Flag to determine whether to check for an existing transaction when a JobExecution is created.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJobRepositoryFactoryBean

public AbstractJobRepositoryFactoryBean()

Method Detail

createJobInstanceDao

protected abstract JobInstanceDao createJobInstanceDao()
                                                throws Exception

Returns:

fully configured JobInstanceDao implementation.

Throws:

Exception

createJobExecutionDao

protected abstract JobExecutionDao createJobExecutionDao()
                                                  throws Exception

Returns:

fully configured JobExecutionDao implementation.

Throws:

Exception

createStepExecutionDao

protected abstract StepExecutionDao createStepExecutionDao()
                                                    throws Exception

Returns:

fully configured StepExecutionDao implementation.

Throws:

Exception

createExecutionContextDao

protected abstract ExecutionContextDao createExecutionContextDao()
                                                          throws Exception

Returns:

fully configured ExecutionContextDao implementation.

Throws:

Exception

getObjectType

public Class<JobRepository> getObjectType()

The type of object to be returned from getObject().

Specified by:

getObjectType in interface FactoryBean

Returns:

JobRepository.class

See Also:

FactoryBean.getObjectType()

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface FactoryBean

setValidateTransactionState

public void setValidateTransactionState(boolean validateTransactionState)

Flag to determine whether to check for an existing transaction when a JobExecution is created. Defaults to true because it is usually a mistake, and leads to problems with restartability and also to deadlocks in multi-threaded steps.

Parameters:

validateTransactionState - the flag to set

setIsolationLevelForCreate

public void setIsolationLevelForCreate(String isolationLevelForCreate)

public setter for the isolation level to be used for the transaction when job execution entities are initially created. The default is ISOLATION_SERIALIZABLE, which prevents accidental concurrent execution of the same job (ISOLATION_REPEATABLE_READ would work as well).

Parameters:

isolationLevelForCreate - the isolation level name to set

See Also:

SimpleJobRepository.createJobExecution(String, org.springframework.batch.core.JobParameters)

setTransactionManager

public void setTransactionManager(PlatformTransactionManager transactionManager)

Public setter for the PlatformTransactionManager.

Parameters:

transactionManager - the transactionManager to set

getTransactionManager

public PlatformTransactionManager getTransactionManager()

The transaction manager used in this factory. Useful to inject into steps and jobs, to ensure that they are using the same instance.

Returns:

the transactionManager

getJobRepository

public JobRepository getJobRepository()
                               throws Exception

Convenience method for clients to grab the JobRepository without a cast.

Returns:

the JobRepository from getObject()

Throws:

Exception - if the repository could not be created

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

getObject

public Object getObject()
                 throws Exception

Specified by:

getObject in interface FactoryBean

Throws:

Exception