Package org.apache.batchee.test
Class SynchronousJobOperator
- java.lang.Object
-
- org.apache.batchee.test.SynchronousJobOperator
-
- All Implemented Interfaces:
javax.batch.operations.JobOperator
public class SynchronousJobOperator extends Object implements javax.batch.operations.JobOperator
An implementation of JobOperator delegating to real JBatch implementation but waiting for start/stop/restart method. Note: would be great to keep this class portable, if not we should just extend BatchKernel and use org.apache.batchee.container.services.kernel.DefaultBatchKernel#jobExecutionDone(org.apache.batchee.container.impl.jobinstance.RuntimeJobExecution)
-
-
Constructor Summary
Constructors Constructor Description SynchronousJobOperator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidabandon(long id)javax.batch.runtime.JobExecutiongetJobExecution(long id)List<javax.batch.runtime.JobExecution>getJobExecutions(javax.batch.runtime.JobInstance jobInstance)javax.batch.runtime.JobInstancegetJobInstance(long id)intgetJobInstanceCount(String name)List<javax.batch.runtime.JobInstance>getJobInstances(String name, int start, int count)Set<String>getJobNames()PropertiesgetParameters(long id)List<Long>getRunningExecutions(String name)List<javax.batch.runtime.StepExecution>getStepExecutions(long id)longrestart(long id, Properties properties)longstart(String name, Properties properties)voidstop(long id)
-
-
-
Method Detail
-
start
public long start(String name, Properties properties) throws javax.batch.operations.JobStartException, javax.batch.operations.JobSecurityException
- Specified by:
startin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.JobStartExceptionjavax.batch.operations.JobSecurityException
-
restart
public long restart(long id, Properties properties) throws javax.batch.operations.JobExecutionAlreadyCompleteException, javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobExecutionNotMostRecentException, javax.batch.operations.JobRestartException, javax.batch.operations.JobSecurityException- Specified by:
restartin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.JobExecutionAlreadyCompleteExceptionjavax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobExecutionNotMostRecentExceptionjavax.batch.operations.JobRestartExceptionjavax.batch.operations.JobSecurityException
-
stop
public void stop(long id) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobExecutionNotRunningException, javax.batch.operations.JobSecurityException- Specified by:
stopin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobExecutionNotRunningExceptionjavax.batch.operations.JobSecurityException
-
abandon
public void abandon(long id) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobExecutionIsRunningException, javax.batch.operations.JobSecurityException- Specified by:
abandonin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobExecutionIsRunningExceptionjavax.batch.operations.JobSecurityException
-
getJobNames
public Set<String> getJobNames() throws javax.batch.operations.JobSecurityException
- Specified by:
getJobNamesin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.JobSecurityException
-
getJobInstanceCount
public int getJobInstanceCount(String name) throws javax.batch.operations.NoSuchJobException, javax.batch.operations.JobSecurityException
- Specified by:
getJobInstanceCountin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExceptionjavax.batch.operations.JobSecurityException
-
getJobInstances
public List<javax.batch.runtime.JobInstance> getJobInstances(String name, int start, int count) throws javax.batch.operations.NoSuchJobException, javax.batch.operations.JobSecurityException
- Specified by:
getJobInstancesin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExceptionjavax.batch.operations.JobSecurityException
-
getRunningExecutions
public List<Long> getRunningExecutions(String name) throws javax.batch.operations.NoSuchJobException, javax.batch.operations.JobSecurityException
- Specified by:
getRunningExecutionsin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExceptionjavax.batch.operations.JobSecurityException
-
getParameters
public Properties getParameters(long id) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobSecurityException
- Specified by:
getParametersin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobSecurityException
-
getJobInstance
public javax.batch.runtime.JobInstance getJobInstance(long id) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobSecurityException- Specified by:
getJobInstancein interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobSecurityException
-
getJobExecutions
public List<javax.batch.runtime.JobExecution> getJobExecutions(javax.batch.runtime.JobInstance jobInstance) throws javax.batch.operations.NoSuchJobInstanceException, javax.batch.operations.JobSecurityException
- Specified by:
getJobExecutionsin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobInstanceExceptionjavax.batch.operations.JobSecurityException
-
getJobExecution
public javax.batch.runtime.JobExecution getJobExecution(long id) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobSecurityException- Specified by:
getJobExecutionin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobSecurityException
-
getStepExecutions
public List<javax.batch.runtime.StepExecution> getStepExecutions(long id) throws javax.batch.operations.NoSuchJobExecutionException, javax.batch.operations.JobSecurityException
- Specified by:
getStepExecutionsin interfacejavax.batch.operations.JobOperator- Throws:
javax.batch.operations.NoSuchJobExecutionExceptionjavax.batch.operations.JobSecurityException
-
-