|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectjp.terasoluna.fw.batch.springsupport.init.AsyncBatchDaemon
public class AsyncBatchDaemon
非同期バッチデーモンクラス。 AsyncBatchDaemonBean.xmlの設定内容に従い 非同期バッチデーモンを起動する。
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!-- ===================== マネージャ定義 ===================== -->
<!-- 非同期バッチ起動用のマネージャ -->
<bean id="jobManager" parent="baseManager">
<property name="name" value="AsyncBatchDaemonManager" />
<property name="collector" ref="batchDaemonJobCollector" />
<property name="workQueueFactory">
<bean class="jp.terasoluna.fw.batch.standard.StandardWorkQueueFactory">
<property name="workerExecutorService" ref="workerExecutorService"/>
<property name="queueProcessor" ref="asyncBatchDaemonQueueProcessor" />
<property name="queueLength" value="10"/>
<property name="multiplicity" ref="multiplicity"/>
</bean>
</property>
<!-- 親ジョブ前処理 -->
<property name="preProcessor" ref="parentJobPreProcessor"/>
<!-- 親ジョブ後処理 -->
<property name="postProcessor" ref="parentJobPostProcessor"/>
</bean>
<!-- 親ジョブ前処理 -->
<bean id="parentJobPreProcessor" parent="transactionalSupportProcessor">
<property name="supportProcessor">
<bean parent="standardSupportProcessor">
<property name="supportProcessorName" ref="parentJobPreProcessorName"/>
</bean>
</property>
</bean>
<!-- 親ジョブ後処理 -->
<bean id="parentJobPostProcessor" parent="transactionalSupportProcessor">
<property name="supportProcessor">
<bean parent="standardSupportProcessor">
<property name="supportProcessorName" ref="parentJobPostProcessorName"/>
</bean>
</property>
</bean>
<!-- ジョブ分割コンテクスト -->
<bean name="jobContext" class="jp.terasoluna.fw.batch.openapi.JobContext" />
<!-- ===================== キュープロセッサ定義 ===================== -->
<bean id="asyncBatchDaemonQueueProcessor" parent="baseQueueProcessor">
<property name="name" value="asyncBatchDaemonQueueProcessor" />
<property name="worker" ref="childJobManager" />
</bean>
<!-- バッチ起動用ワーカ -->
<bean id="childJobManager" class="jp.terasoluna.fw.batch.springsupport.init.JobExecutor">
<constructor-arg>
<value>/common/FrameworkBean.xml,/common/dataAccessContext-batch.xml,/common/ThreadPoolContext-AsyncBatch.xml,/common/ValidationContext-AsyncBatch.xml</value>
</constructor-arg>
<property name="async" value="true" />
<!-- 親ジョブ前処理 -->
<property name="preJobProcessor" ref="preJobProcessor"/>
<!-- 親ジョブ後処理 -->
<property name="postJobProcessor" ref="postJobProcessor"/>
<!-- ジョブパラメータの区切り文字 -->
<property name="jobParametersSplitStr" value="\\,"/>
</bean>
<!-- ジョブ前処理 -->
<bean id="preJobProcessor" parent="transactionalSupportProcessor">
<property name="supportProcessor">
<bean parent="standardSupportProcessor">
<property name="supportProcessorName" ref="jobPreProcessorName"/>
<property name="supportLogicList">
<list>
<bean class="jp.terasoluna.fw.batch.springsupport.init.AsyncJobPreLogic">
<property name="jobControlTableHandler" ref="JobControlTableHandler" />
</bean>
</list>
</property>
</bean>
</property>
</bean>
<!-- ジョブ後処理 -->
<bean id="postJobProcessor" parent="transactionalSupportProcessor">
<property name="supportProcessor">
<bean parent="standardSupportProcessor">
<property name="supportProcessorName" ref="jobPostProcessorName"/>
<property name="supportLogicList">
<list>
<bean class="jp.terasoluna.fw.batch.springsupport.init.AsyncJobPostLogic">
<property name="jobControlTableHandler" ref="JobControlTableHandler" />
</bean>
</list>
</property>
</bean>
</property>
</bean>
<!-- コレクタ -->
<bean id="batchDaemonJobCollector" class="jp.terasoluna.fw.batch.init.JobRequestInfoCollector">
<property name="collectedDataHandlerFactory">
<bean class="jp.terasoluna.fw.batch.init.JobRequestInfoHandlerFactory"/>
</property>
<property name="jobControlTableHandler" ref="JobControlTableHandler" />
<property name="intervalSeconds" value="10" />
<property name="refreshCount" value="20" />
</bean>
<!-- JobStatus設定 -->
<bean id="MonitorableJobStatus" class="jp.terasoluna.fw.batch.monitor.MonitorableTransactionalJobStatus">
<property name="mbeanRegister" ref="MBeanRegister"/>
<property name="transactionManager" ref="transactionManager" />
<property name="useSavepoint" ref="useSavepoint" />
<property name="partitionNo" value="-1"/>
</bean>
<bean id="JobStatus" class="jp.terasoluna.fw.batch.springsupport.transaction.TransactionalJobStatus">
<property name="transactionManager" ref="transactionManager" />
<property name="useSavepoint" ref="useSavepoint" />
<property name="partitionNo" value="-1"/>
</bean>
<!-- ジョブ監視を行うか? -->
<bean id="useMonitorable" class="org.springframework.beans.factory.config.FieldRetrievingFactoryBean">
<property name="staticField" value="java.lang.Boolean.FALSE"/>
</bean>
<!-- ===================== ジョブ管理テーブル用ハンドラ ===================== -->
<bean id="JobControlTableHandler" class="jp.terasoluna.fw.batch.init.JobControlTableHandlerImpl">
<property name="queryDAO" ref="queryDAO" />
<property name="updateDAO" ref="updateDAO" />
</bean>
<!-- ===================== スレッドプール作成時のサイズ ===================== -->
<bean id="threadSize" class="jp.terasoluna.fw.batch.springsupport.standard.ThreadSizeFactoryBean">
<property name="multiplicity" ref="multiplicity"/>
</bean>
<bean id="multiplicity" class="java.lang.Integer">
<constructor-arg>
<value>3</value>
</constructor-arg>
</bean>
</beans>
フィールドの概要 | |
---|---|
private static java.lang.String |
ASYNC_BATCH_DAEMON_BEAN_DEFINITION_NAME
フレームワークBean定義ファイル名。 |
private static java.lang.String[] |
ASYNCBATCHDAEMON_START_PARAMETER
非同期バッチデーモン起動用引数。 |
private static org.apache.commons.logging.Log |
log
ログクラス。 |
コンストラクタの概要 | |
---|---|
AsyncBatchDaemon()
|
メソッドの概要 | |
---|---|
static void |
main(java.lang.String[] args)
非同期ジョブ起動用Mainメソッド。 |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
フィールドの詳細 |
---|
private static final org.apache.commons.logging.Log log
private static final java.lang.String ASYNC_BATCH_DAEMON_BEAN_DEFINITION_NAME
private static final java.lang.String[] ASYNCBATCHDAEMON_START_PARAMETER
コンストラクタの詳細 |
---|
public AsyncBatchDaemon()
メソッドの詳細 |
---|
public static void main(java.lang.String[] args) throws java.lang.Throwable
args
- 起動時の引数(使用されない)
java.lang.Throwable
- Throwable
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |