67.3. プロセスエンジンのトランザクション

ユーザー定義トランザクションを使用するには、環境でトランザクションマネージャーを登録する必要があります。

以下のサンプルコードはトランザクションマネージャーを登録し、JTA 呼び出しを使用してトランザクション境界を指定します。

// Create the entity manager factory
EntityManagerFactory emf = EntityManagerFactoryManager.get().getOrCreate("org.jbpm.persistence.jpa");
TransactionManager tm = TransactionManagerServices.getTransactionManager();

// Set up the runtime environment
RuntimeEnvironment environment = RuntimeEnvironmentBuilder.Factory.get()
.newDefaultBuilder()
.addAsset(ResourceFactory.newClassPathResource("MyProcessDefinition.bpmn2"), ResourceType.BPMN2)
    .addEnvironmentEntry(EnvironmentName.TRANSACTION_MANAGER, tm)
    .get();

// Get the KIE session
RuntimeManager manager = RuntimeManagerFactory.Factory.get().newPerRequestRuntimeManager(environment);
RuntimeEngine runtime = manager.getRuntimeEngine(ProcessInstanceIdContext.get());
KieSession ksession = runtime.getKieSession();

// Start the transaction
UserTransaction ut = InitialContext.doLookup("java:comp/UserTransaction");
ut.begin();

// Perform multiple commands inside one transaction
ksession.insert( new Person( "John Doe" ) );
ksession.startProcess("MyProcess");

// Commit the transaction
ut.commit();

UserTransaction、TransactionManager、TransactionSynchronizationRegistry などのトランザクション関連のオブジェクトが JNDI に登録されているため、root クラスパスに jndi.properties ファイルを指定して JNDI InitialContextFactory オブジェクトを作成する必要があります。

プロジェクトに jbpm-test モジュールが含まれる場合、このファイルはすでにデフォルトで含まれています。

それ以外の場合は、以下の内容で jndi.properties ファイルを作成してください。

java.naming.factory.initial=org.jbpm.test.util.CloseSafeMemoryContextFactory
org.osjava.sj.root=target/test-classes/config
org.osjava.jndi.delimiter=/
org.osjava.sj.jndi.shared=true

この設定では、simple-jndi:simple-jndi アーティファクトがプロジェクトのクラスパスにあることを前提としています。異なる JNDI 実装を使用することもできます。

デフォルトでは、Narayana JTA トランザクションマネージャーが使用されます。別の JTA トランザクションマネージャーを使用する場合は、persistence.xml ファイルを変更して必要なトランザクションマネージャーを使用できます。たとえば、アプリケーションが Red Hat JBoss EAP バージョン 7 以降で実行する場合は、JBoss トランザクションマネージャーを使用できます。この場合は、persistence.xml ファイルのトランザクションマネージャープロパティーを変更します。

<property name="hibernate.transaction.jta.platform" value="org.hibernate.service.jta.platform.internal.JBossAppServerJtaPlatform" />

synchronized (ksession) {
    try {
        tx.begin();

        // use ksession
        // application logic

        tx.commit();
    } catch (Exception e) {
        //...
    }
}

EJB Bean などの CMT (container-managed transaction) モードで実行するアプリケーションにプロセスエンジンを埋め込む場合は、追加の設定を完了する必要があります。この設定は、アプリケーションが CMT アプリケーションが JNDI から UserTransaction インスタンス (WebSphere Application Server など) にアクセスできないアプリケーションサーバーで実行される場合に特に重要になります。

プロセスエンジンのデフォルトトランザクションマネージャーの実装は、UserTransaction を使用してトランザクションの状態をクエリーし、ステータスを使用してトランザクションを開始するかどうかを判断します。UserTransaction インスタンスにアクセスできない環境では、この実装は失敗します。

CMT 環境で適切な実行を有効にするために、プロセスエンジンは専用のトランザクションマネージャーの実装 (org.jbpm.persistence.jta.ContainerManagedTransactionManager) を提供します。このトランザクションマネージャーはトランザクションがアクティブであることを想定し、getStatus() メソッドが呼び出されると常に ACTIVE を返します。トランザクションマネージャーはコンテナー管理トランザクションモードでこれらの操作に影響を与えることができないため、begin、commit、rollback などの操作は操作できません。

このトランザクションマネージャーを設定するには、以下の手順を行います。

プロセスエンジンがトランザクションのコミット時に別のトランザクションが同時にコミットされることが原因で、コミット操作に失敗することがあります。この場合、プロセスエンジンはトランザクションを再試行する必要があります。

再試行に複数回失敗すると、トランザクションは完全に失敗します。

JVM システムプロパティーを使用して、再試行プロセスを制御できます。