com.nec.webotx.batch.util
クラス AbstractDBRetry

java.lang.Object
  上位を拡張 com.nec.webotx.batch.util.AbstractDBRetry
すべての実装されたインタフェース:
InitializingBean
直系の既知のサブクラス:
BSDBRetryStepListener

public abstract class AbstractDBRetry
extends Object
implements InitializingBean

DBリトライ機能のための共通実装です

バージョン:
Batch Server V8.41.01

入れ子のクラスの概要
protected  class AbstractDBRetry.CouldNotRertyError
           
protected static class AbstractDBRetry.DBRetryContext
           
protected  class AbstractDBRetry.DBRetryInterruptedException
           
protected  class AbstractDBRetry.DBRetryOverException
           
 
フィールドの概要
protected static Log executionLog
           
protected static com.nec.webotx.batch.core.message.JBSMessage message
           
 
コンストラクタの概要
AbstractDBRetry()
           
 
メソッドの概要
 void afterPropertiesSet()
           
protected  void debugLog(com.nec.webotx.batch.core.message.JBSMessageId msgId, Object... objects)
           
protected  void doRetry()
          設定にしたがってDBの正常性確認を行います。
protected static AbstractDBRetry.DBRetryContext endRetryContext()
           
protected  BackOffPolicy getBackoffPolicy()
           
protected  List<Class<? extends Throwable>> getRetryableExceptionClasses()
           
protected  AbstractDBRetry.DBRetryContext getRetryContext()
           
protected  long getRetryInterval()
           
protected  int getRetryLimit()
           
protected  List<DataSource> getTargetDataSources()
           
protected  String getValidationQuery()
           
protected  void infoLog(com.nec.webotx.batch.core.message.JBSMessageId msgId, Object... objects)
           
 void setBackoffPolicy(BackOffPolicy backoffPolicyValue)
           
 void setRetryableExceptionClasses(List<Class<? extends Throwable>> retryableExceptionClassesValue)
           
 void setRetryInterval(long retryIntervalValue)
           
 void setRetryLimit(int retryLimitValue)
           
 void setTargetDataSources(List<DataSource> targetDataSourcesValue)
           
 void setValidationQuery(String validationQueryValue)
           
protected static AbstractDBRetry.DBRetryContext startRetryContext()
           
protected  void traceLog(com.nec.webotx.batch.core.message.JBSMessageId msgId, Object... objects)
           
protected  void validateConnection(Connection con)
           
protected  void validateDataSource(DataSource ds)
           
protected  void warnLog(com.nec.webotx.batch.core.message.JBSMessageId msgId, Object... objects)
           
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

フィールドの詳細

message

protected static com.nec.webotx.batch.core.message.JBSMessage message

executionLog

protected static Log executionLog
コンストラクタの詳細

AbstractDBRetry

public AbstractDBRetry()
メソッドの詳細

infoLog

protected void infoLog(com.nec.webotx.batch.core.message.JBSMessageId msgId,
                       Object... objects)

warnLog

protected void warnLog(com.nec.webotx.batch.core.message.JBSMessageId msgId,
                       Object... objects)

debugLog

protected void debugLog(com.nec.webotx.batch.core.message.JBSMessageId msgId,
                        Object... objects)

traceLog

protected void traceLog(com.nec.webotx.batch.core.message.JBSMessageId msgId,
                        Object... objects)

doRetry

protected void doRetry()
                throws AbstractDBRetry.DBRetryOverException,
                       AbstractDBRetry.DBRetryInterruptedException
設定にしたがってDBの正常性確認を行います。

例外:
AbstractDBRetry.DBRetryOverException
AbstractDBRetry.DBRetryInterruptedException

validateDataSource

protected void validateDataSource(DataSource ds)
                           throws SQLException
例外:
SQLException

validateConnection

protected void validateConnection(Connection con)
                           throws SQLException
例外:
SQLException

setRetryLimit

public void setRetryLimit(int retryLimitValue)
パラメータ:
retryLimit - リトライリミット

setRetryInterval

public void setRetryInterval(long retryIntervalValue)
パラメータ:
retryInterval - リトライ間隔

setRetryableExceptionClasses

public void setRetryableExceptionClasses(List<Class<? extends Throwable>> retryableExceptionClassesValue)
パラメータ:
retryableExceptionClasses - リトライ可能例外

setValidationQuery

public void setValidationQuery(String validationQueryValue)
パラメータ:
validationQuery - DB正常性確認用のSQL

setTargetDataSources

public void setTargetDataSources(List<DataSource> targetDataSourcesValue)
パラメータ:
targetDataSources - DB正常性確認を行うDataSource

setBackoffPolicy

public void setBackoffPolicy(BackOffPolicy backoffPolicyValue)
パラメータ:
backoffPolicy - BackOffPolicyを指定します。

getRetryLimit

protected int getRetryLimit()

getRetryInterval

protected long getRetryInterval()

getRetryableExceptionClasses

protected List<Class<? extends Throwable>> getRetryableExceptionClasses()

getValidationQuery

protected String getValidationQuery()

getTargetDataSources

protected List<DataSource> getTargetDataSources()

getBackoffPolicy

protected BackOffPolicy getBackoffPolicy()

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception
定義:
インタフェース InitializingBean 内の afterPropertiesSet
例外:
Exception

getRetryContext

protected AbstractDBRetry.DBRetryContext getRetryContext()

startRetryContext

protected static AbstractDBRetry.DBRetryContext startRetryContext()

endRetryContext

protected static AbstractDBRetry.DBRetryContext endRetryContext()


Copyright © 2012 NEC Corporation. All Rights Reserved.