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
GlueJobOperator()



           
 



Method Summary




 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