org.springframework.xd.dirt.plugins.job.support

Class JobLaunchingJobRepository

java.lang.Object

org.springframework.batch.core.repository.support.SimpleJobRepository

org.springframework.xd.dirt.plugins.job.support.JobLaunchingJobRepository

All Implemented Interfaces:

org.springframework.batch.core.repository.JobRepository

public class JobLaunchingJobRepository
extends org.springframework.batch.core.repository.support.SimpleJobRepository

This JobRepository implementation provides the same functionality as Spring Batch's SimpleJobRepository however it does not re-hydrate a ExecutionContext when querying for a JobExecution or a StepExecution. This is done to prevent class loading issues when launching jobs within Spring XD.

Author:

Michael Minella

Constructor Summary

Constructors

Constructor and Description
JobLaunchingJobRepository(org.springframework.batch.core.repository.dao.JobInstanceDao jobInstanceDao, org.springframework.batch.core.repository.dao.JobExecutionDao jobExecutionDao, org.springframework.batch.core.repository.dao.StepExecutionDao stepExecutionDao, org.springframework.batch.core.repository.dao.ExecutionContextDao executionContextDao)

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.batch.core.JobExecution	getLastJobExecution(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters) Returns the last JobExecution for the requested job without rehydrating the related ExecutionContext.
org.springframework.batch.core.StepExecution	getLastStepExecution(org.springframework.batch.core.JobInstance jobInstance, java.lang.String stepName) Returns the last StepExecution for the requested step without rehydrating the related ExecutionContext.

Methods inherited from class org.springframework.batch.core.repository.support.SimpleJobRepository

add, addAll, createJobExecution, createJobExecution, createJobInstance, getStepExecutionCount, isJobInstanceExists, update, update, updateExecutionContext, updateExecutionContext

Methods inherited from class java.lang.Object

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

Constructor Detail

JobLaunchingJobRepository

public JobLaunchingJobRepository(org.springframework.batch.core.repository.dao.JobInstanceDao jobInstanceDao,
                         org.springframework.batch.core.repository.dao.JobExecutionDao jobExecutionDao,
                         org.springframework.batch.core.repository.dao.StepExecutionDao stepExecutionDao,
                         org.springframework.batch.core.repository.dao.ExecutionContextDao executionContextDao)

Method Detail

getLastJobExecution

public org.springframework.batch.core.JobExecution getLastJobExecution(java.lang.String jobName,
                                                              org.springframework.batch.core.JobParameters jobParameters)

Returns the last JobExecution for the requested job without rehydrating the related ExecutionContext.

Specified by:

getLastJobExecution in interface org.springframework.batch.core.repository.JobRepository

Overrides:

getLastJobExecution in class org.springframework.batch.core.repository.support.SimpleJobRepository

Parameters:

jobName - The name of the job

jobParameters - The parameters of the job

Returns:

The related JobExecution

getLastStepExecution

public org.springframework.batch.core.StepExecution getLastStepExecution(org.springframework.batch.core.JobInstance jobInstance,
                                                                java.lang.String stepName)

Returns the last StepExecution for the requested step without rehydrating the related ExecutionContext.

Specified by:

getLastStepExecution in interface org.springframework.batch.core.repository.JobRepository

Overrides:

getLastStepExecution in class org.springframework.batch.core.repository.support.SimpleJobRepository

Parameters:

jobInstance - The JobInstance the step should come from

stepName - The name of the step to find

Returns:

The related StepExecution