Package com.infoteria.asteria.flowengine2.transaction

Class TransactionTest

java.lang.Object
com.infoteria.asteria.flowengine2.transaction.AbstractExtendedTransaction
com.infoteria.asteria.flowengine2.transaction.TransactionTest
All Implemented Interfaces:
Transaction, ExtendedTransaction
public class TransactionTest extends AbstractExtendedTransaction
トランザクションのテストクラス
コールバックメソッド内でわざとエラーを発生させたり、 prepare時にスリープさせることができます。

  • Constructor Details

    • TransactionTest

      public TransactionTest(String name)

    • TransactionTest

      public TransactionTest(String name, int recoveryPolicy, int priority)

  • Method Details

    • start

      public void start(ExecuteContext context, Xid xid) throws FlowException
      指定のXidでトランザクションを開始を実装します。
      Specified by:
      start in interface ExtendedTransaction
      Overrides:
      start in class AbstractExtendedTransaction
      Throws:
      FlowException

    • getSleepTime

      public long getSleepTime()
      prepare時のスリープ時間を取得します。

    • setSleepTime

      public void setSleepTime(long n)
      prepare時のスリープ時間を設定します。

    • isPrepareError

      public boolean isPrepareError()
      prepareメソッド内でRuntimeExceptionを発生させるかどうかを返します。

    • setPrepareError

      public void setPrepareError(boolean b)
      prepareメソッド内でRuntimeExceptionを発生させるかどうかを設定します。

    • isCommitError

      public boolean isCommitError()
      commitメソッド内でRuntimeExceptionを発生させるかどうかを返します。

    • setCommitError

      public void setCommitError(boolean b)
      commitメソッド内でRuntimeExceptionを発生させるかどうかを設定します。

    • isRollbackError

      public boolean isRollbackError()
      rollbackメソッド内でRuntimeExceptionを発生させるかどうかを返します。

    • setRollbackError

      public void setRollbackError(boolean b)
      rollbackメソッド内でRuntimeExceptionを発生させるかどうかを設定します。

    • isPrepareException

      public boolean isPrepareException()
      prepareメソッド内でTransactionExceptionを発生させるかどうかを返します。

    • setPrepareException

      public void setPrepareException(boolean b)
      prepareメソッド内でTransactionExceptionを発生させるかどうかを設定します。

    • isCommitException

      public boolean isCommitException()
      commitメソッド内でTransactionExceptionを発生させるかどうかを返します。

    • setCommitException

      public void setCommitException(boolean b)
      commitメソッド内でTransactionExceptionを発生させるかどうかを設定します。

    • isRollbackException

      public boolean isRollbackException()
      rollbackメソッド内でTransactionExceptionを発生させるかどうかを返します。

    • setRollbackException

      public void setRollbackException(boolean b)
      rollbackメソッド内でTransactionExceptionを発生させるかどうかを設定します。

    • prepare

      public void prepare(ExecuteContext context) throws FlowException
      トランザクションがcommit可能かどうかを確認します。
      Specified by:
      prepare in interface ExtendedTransaction
      Overrides:
      prepare in class AbstractExtendedTransaction
      Throws:
      FlowException

    • commit

      public void commit(ExecuteContext context) throws FlowException
      コネクションをcommitします。
      Throws:
      FlowException

    • rollback

      public void rollback(ExecuteContext context) throws FlowException
      コネクションをrollbackします。
      Throws:
      FlowException