非同期実行(DBポーリング)

@Bean
public AutomaticJobRegistrar automaticJobRegistrar(JobRegistry jobRegistry,
        ApplicationContextFactory[] applicationContextFactories) throws Exception {
    final AutomaticJobRegistrar automaticJobRegistrar = new AutomaticJobRegistrar();
    final DefaultJobLoader defaultJobLoader = new DefaultJobLoader();
    defaultJobLoader.setJobRegistry(jobRegistry);
    automaticJobRegistrar.setApplicationContextFactories(
            applicationContextFactories);
    automaticJobRegistrar.setJobLoader(defaultJobLoader);
    automaticJobRegistrar.afterPropertiesSet();
    return automaticJobRegistrar;
}

@Bean
public ApplicationContextFactory[] applicationContextFactories(
        final ApplicationContext ctx) throws IOException {
    return new ApplicationContextFactoryHelper(ctx).load(
            "classpath:org/terasoluna/batch/jobs/**/*.class", // For all (1)
            "classpath:org/terasoluna/batch/jobs/async/**/*.class", // For the async directory and below (2)
            "classpath:org/terasoluna/batch/jobs/CASE100/SpecialJob.class"); // For a specific job (3)
}

<bean id="automaticJobRegistrar"
      class="org.springframework.batch.core.configuration.support.AutomaticJobRegistrar">
    <property name="applicationContextFactories">
        <bean class="org.springframework.batch.core.configuration.support.ClasspathXmlApplicationContextsFactoryBean">
            <property name="resources">
                <list>
                    <!-- For all -->
                    <value>classpath:/META-INF/jobs/**/*.xml</value> <!-- (1) -->
                    <!-- For the async directory and below -->
                    <value>classpath:/META-INF/jobs/async/**/*.xml</value> <!-- (2) -->
                    <!-- For a specific job -->
                    <value>classpath:/META-INF/jobs/CASE100/SpecialJob.xml</value> <!-- (3) -->
                </list>
            </property>
        </bean>
    </property>
    <property name="jobLoader">
        <bean class="org.springframework.batch.core.configuration.support.DefaultJobLoader"
              p:jobRegistry-ref="jobRegistry" />
    </property>
</bean>

$ # Start AsyncBatchDaemon
$ java -cp dependency/* org.terasoluna.batch.async.db.AsyncBatchDaemon

$ # Start AsyncBatchDaemon
$ java -cp dependency/* org.terasoluna.batch.async.db.AsyncBatchDaemon com.example.batch.tutorial.config.CustomizedAsyncBatchDaemonConfig

$ # Start AsyncBatchDaemon
$ java -cp dependency/* org.terasoluna.batch.async.db.AsyncBatchDaemon

$ # Start AsyncBatchDaemon
$ java -cp dependency/* org.terasoluna.batch.async.db.AsyncBatchDaemon META-INF/spring/customized-async-batch-daemon.xml

@Bean
public MapperFactoryBean<CustomizedBatchJobRequestRepository> batchJobRequestRepository(
        @Qualifier("adminSqlSessionFactory") SqlSessionFactory adminSqlSessionFactory) {
    final MapperFactoryBean<CustomizedBatchJobRequestRepository> mapperFactoryBean = new MapperFactoryBean<>();
    mapperFactoryBean.setMapperInterface(CustomizedBatchJobRequestRepository.class); // (1)
    mapperFactoryBean.setSqlSessionFactory(adminSqlSessionFactory);
    return mapperFactoryBean;
}

 <!--(1) -->
<bean id="batchJobRequestRepository"
      class="org.mybatis.spring.mapper.MapperFactoryBean"
      p:mapperInterface="jp.co.ntt.fw.macchinetta.batch.extend.repository.CustomizedBatchJobRequestRepository"
      p:sqlSessionFactory-ref="adminSqlSessionFactory" />

@Bean
public MapperFactoryBean<CustomizedBatchJobRequestRepository> batchJobRequestRepository(
        @Qualifier("adminSqlSessionFactory") SqlSessionFactory adminSqlSessionFactory) {
    final MapperFactoryBean<CustomizedBatchJobRequestRepository> mapperFactoryBean = new MapperFactoryBean<>();
    mapperFactoryBean.setMapperInterface(CustomizedBatchJobRequestRepository.class); // (1)
    mapperFactoryBean.setSqlSessionFactory(adminSqlSessionFactory);
    return mapperFactoryBean;
}

@Bean
public JobRequestPollTask jobRequestPollTask(@Qualifier("adminTransactionManager") DataSourceTransactionManager adminTransactionManager,
                                             JobOperator jobOperator,
                                             MapperFactoryBean<CustomizedBatchJobRequestRepository> batchJobRequestRepository,
                                             @Qualifier("daemonTaskExecutor") ThreadPoolTaskExecutor daemonTaskExecutor,
                                             AutomaticJobRegistrar automaticJobRegistrar)  throws Exception {

    JobRequestPollTask jobRequestPollTask = new JobRequestPollTask(batchJobRequestRepository.getObject(), adminTransactionManager, daemonTaskExecutor, jobOperator,
            automaticJobRegistrar);
    final Map<String, Object> pollingQueryParam = new LinkedHashMap<>();
    pollingQueryParam.put("groupId", groupId); // (2)

    jobRequestPollTask.setOptionalPollingQueryParams(pollingQueryParam); // (3)
    return jobRequestPollTask;
}

 <!--(1) -->
<bean id="batchJobRequestRepository"
      class="org.mybatis.spring.mapper.MapperFactoryBean"
      p:mapperInterface="jp.co.ntt.fw.macchinetta.batch.extend.repository.CustomizedBatchJobRequestRepository"
      p:sqlSessionFactory-ref="adminSqlSessionFactory" />

<bean id="jobRequestPollTask"
      class="org.terasoluna.batch.async.db.JobRequestPollTask"
      c:transactionManager-ref="adminTransactionManager"
      c:jobOperator-ref="jobOperator"
      c:batchJobRequestRepository-ref="batchJobRequestRepository"
      c:daemonTaskExecutor-ref="daemonTaskExecutor"
      c:automaticJobRegistrar-ref="automaticJobRegistrar"
      p:optionalPollingQueryParams-ref="pollingQueryParam" /> <!-- (3) -->

<bean id="pollingQueryParam"
      class="org.springframework.beans.factory.config.MapFactoryBean">
      <property name="sourceMap">
            <map>
                <entry key="groupId" value="${GROUP_ID}"/>  <!-- (2) -->
            </map>
      </property>
</bean>