org.jberet.repository

Class InfinispanRepository

java.lang.Object

org.jberet.repository.AbstractRepository

org.jberet.repository.InfinispanRepository

All Implemented Interfaces:

JobRepository

public final class InfinispanRepository
extends AbstractRepository

Constructor Summary

Constructors

Constructor and Description
InfinispanRepository(org.infinispan.configuration.cache.Configuration infinispanConfig)
InfinispanRepository(String infinispanXml)

Method Summary

Modifier and Type	Method and Description
void	addPartitionExecution(StepExecutionImpl enclosingStepExecution, PartitionExecutionImpl partitionExecution)
int	countStepStartTimes(String stepName, long jobInstanceId)
static InfinispanRepository	create(org.infinispan.configuration.cache.Configuration infinispanConfig)
static InfinispanRepository	create(Properties configProperties)
JobExecutionImpl	createJobExecution(JobInstanceImpl jobInstance, Properties jobParameters)
JobInstanceImpl	createJobInstance(Job job, String applicationName, ClassLoader classLoader)
StepExecutionImpl	findOriginalStepExecutionForRestart(String stepName, JobExecutionImpl jobExecutionToRestart0, ClassLoader classLoader)
JobExecutionImpl	getJobExecution(long jobExecutionId)
List<javax.batch.runtime.JobExecution>	getJobExecutions(javax.batch.runtime.JobInstance jobInstance)
javax.batch.runtime.JobInstance	getJobInstance(long jobInstanceId)
int	getJobInstanceCount(String jobName)
List<javax.batch.runtime.JobInstance>	getJobInstances(String jobName)
List<PartitionExecutionImpl>	getPartitionExecutions(long stepExecutionId, StepExecutionImpl stepExecution, boolean notCompletedOnly, ClassLoader classLoader)
List<Long>	getRunningExecutions(String jobName) Gets the ids of running job executions belonging to a specific job.
List<javax.batch.runtime.StepExecution>	getStepExecutions(long jobExecutionId, ClassLoader classLoader)
void	removeJob(String jobId)
void	removeJobExecutions(JobExecutionSelector jobExecutionSelector) Removes JobExecutions based on the criteria specified in jobExecutionSelector.
void	removeJobInstance(long jobInstanceIdToRemove)
void	savePersistentData(javax.batch.runtime.JobExecution jobExecution, AbstractStepExecution stepOrPartitionExecution)
void	updateJobExecution(JobExecutionImpl jobExecution, boolean fullUpdate, boolean saveJobParameters)
void	updateStepExecution(javax.batch.runtime.StepExecution stepExecution)

Methods inherited from class org.jberet.repository.AbstractRepository

addJob, addStepExecution, createStepExecution, getJob, getJobNames, jobExists

Methods inherited from class java.lang.Object

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

Constructor Detail

InfinispanRepository

public InfinispanRepository(org.infinispan.configuration.cache.Configuration infinispanConfig)

InfinispanRepository

public InfinispanRepository(String infinispanXml)

Method Detail

create

public static InfinispanRepository create(org.infinispan.configuration.cache.Configuration infinispanConfig)

create

public static InfinispanRepository create(Properties configProperties)

removeJob

public void removeJob(String jobId)

Specified by:

removeJob in interface JobRepository

Overrides:

removeJob in class AbstractRepository

createJobInstance

public JobInstanceImpl createJobInstance(Job job,
                                         String applicationName,
                                         ClassLoader classLoader)

removeJobInstance

public void removeJobInstance(long jobInstanceIdToRemove)

removeJobExecutions

public void removeJobExecutions(JobExecutionSelector jobExecutionSelector)

Description copied from interface: JobRepository

Removes JobExecutions based on the criteria specified in jobExecutionSelector.

Parameters:

jobExecutionSelector - criteria for which JobExecutions to remove

getJobInstance

public javax.batch.runtime.JobInstance getJobInstance(long jobInstanceId)

getJobInstances

public List<javax.batch.runtime.JobInstance> getJobInstances(String jobName)

getJobInstanceCount

public int getJobInstanceCount(String jobName)

createJobExecution

public JobExecutionImpl createJobExecution(JobInstanceImpl jobInstance,
                                           Properties jobParameters)

getJobExecution

public JobExecutionImpl getJobExecution(long jobExecutionId)

getJobExecutions

public List<javax.batch.runtime.JobExecution> getJobExecutions(javax.batch.runtime.JobInstance jobInstance)

getStepExecutions

public List<javax.batch.runtime.StepExecution> getStepExecutions(long jobExecutionId,
                                                                 ClassLoader classLoader)

savePersistentData

public void savePersistentData(javax.batch.runtime.JobExecution jobExecution,
                               AbstractStepExecution stepOrPartitionExecution)

Specified by:

savePersistentData in interface JobRepository

Overrides:

savePersistentData in class AbstractRepository

updateStepExecution

public void updateStepExecution(javax.batch.runtime.StepExecution stepExecution)

updateJobExecution

public void updateJobExecution(JobExecutionImpl jobExecution,
                               boolean fullUpdate,
                               boolean saveJobParameters)

Specified by:

updateJobExecution in interface JobRepository

Overrides:

updateJobExecution in class AbstractRepository

findOriginalStepExecutionForRestart

public StepExecutionImpl findOriginalStepExecutionForRestart(String stepName,
                                                             JobExecutionImpl jobExecutionToRestart0,
                                                             ClassLoader classLoader)

addPartitionExecution

public void addPartitionExecution(StepExecutionImpl enclosingStepExecution,
                                  PartitionExecutionImpl partitionExecution)

Specified by:

addPartitionExecution in interface JobRepository

Overrides:

addPartitionExecution in class AbstractRepository

getPartitionExecutions

public List<PartitionExecutionImpl> getPartitionExecutions(long stepExecutionId,
                                                           StepExecutionImpl stepExecution,
                                                           boolean notCompletedOnly,
                                                           ClassLoader classLoader)

Specified by:

getPartitionExecutions in interface JobRepository

Overrides:

getPartitionExecutions in class AbstractRepository

countStepStartTimes

public int countStepStartTimes(String stepName,
                               long jobInstanceId)

getRunningExecutions

public List<Long> getRunningExecutions(String jobName)

Description copied from interface: JobRepository

Gets the ids of running job executions belonging to a specific job.

Parameters:

jobName - the name of the job, not null

Returns:

a list of job execution ids

See Also:

JobOperatorImpl.getRunningExecutions(java.lang.String)