com.poscoict.glueframework.batch.operator

Class GlueJobOperator

java.lang.Object

com.poscoict.glueframework.batch.operator.GlueJobOperator

All Implemented Interfaces:

InitializingBean

public class GlueJobOperator
extends Object
implements InitializingBean

Job Restarter(JobOperator).

 Bean Property
 
 - dataSource : (필수) DataSource 참조 bean id
 
 - jobOperator : (필수) JobOperator 참조 bean id
 
 - restartSql : (필수) 
               default : INSERT INTO BATCH_JOB_OPERATOR_INFO (JOB_EXECUTION_ID, REF_JOB_EXECUTION_ID, MESSAGE) VALUES (?,?,?)
 
 
 예제
 사용 예# 1
 
     <bean id="JobRestarter" class="com.poscoict.glueframework.batch.operator.GlueJobOperator">
         <property name="dataSource" ref="dataSource"/>
         <property name="jobOperator" ref="jobOperator"/>
     </bean>
 
 
 
 참고 : schema-oracle-batch-plut.sql ( glue-batch.jar!/db_script )
 
 
 참고 : applicationContext.xml
 
     <bean id="serviceManager" class="com.poscoict.glueframework.biz.control.GlueServiceManagerImpl">
         <property name="serviceLoader" ref="serviceLoader" />
         <property name="cacheManager" ref="cacheManager" />
     </bean>
     <bean id="cacheManager" .../>
     <bean id="serviceLoader" .../>
     <bean id="dataSource" .../>
     <bean id="JobRestarter" .../>
     <bean id="jobOperator" class="org.springframework.batch.core.launch.support.SimpleJobOperator">
         <property name="jobLauncher" ref="jobLauncher"/>
         <property name="jobExplorer" ref="jobExplorer"/>
         <property name="jobRepository" ref="jobRepository"/>
         <property name="jobRegistry" ref="jobRegistry"/>
     </bean>
     <bean id="jobLauncher" .../>
     <bean id="jobExplorer" .../>
     <bean id="jobRepository" .../>
     <bean id="jobRegistry" .../>
 <batch:job id="job" .../>

Constructor Summary

Constructors

Constructor and Description
GlueJobOperator()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
Long	restart(long executionId, String message) JobOperator 를 통해 실패하거나 정지된 JobExceution을 재시작하고 'BATCH_JOB_OPERATOR_INFO' 에 기록한다.
void	setDataSource(DataSource dataSource) setter method for DI.
void	setJobOperator(org.springframework.batch.core.launch.JobOperator jobOperator) setter method for DI.
void	setRestartSql(String restartSql) setter method for DI.

Methods inherited from class java.lang.Object

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

Constructor Detail

GlueJobOperator

public GlueJobOperator()

Method Detail

setRestartSql

public void setRestartSql(String restartSql)

setter method for DI.

Parameters:

restartSql -

setJobOperator

public void setJobOperator(org.springframework.batch.core.launch.JobOperator jobOperator)

setter method for DI.

Parameters:

jobOperator -

setDataSource

public void setDataSource(DataSource dataSource)

setter method for DI.

Parameters:

dataSource -

restart

public Long restart(long executionId,
                    String message)
             throws Exception

JobOperator 를 통해 실패하거나 정지된 JobExceution을 재시작하고 'BATCH_JOB_OPERATOR_INFO' 에 기록한다.

Parameters:

executionId - - 재시작하고자 하는 JoB Execution ID

message -

Returns:

Throws:

Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception