Jolt クラス・ライブラリの使い方

Jolt クラスを使用すると、ログオン/ログオフ、同期型のサービス呼び出し、トランザクションの開始、トランザクションのコミット、トランザクションのロールバックなどの基本的なトランザクション処理を実行できます。次の節では、これらの機能を実行するための Jolt クラスの使い方を説明します。

Jolt クラス・ライブラリを使用して、マルチスレッド化されたアプリケーションを開発したり、Tuxedo 固有のバッファ型を定義したり、イベントや任意通知型メッセージのサブスクライブを実行することもできます。これらの機能については、後の節で説明します。

ログオン/ログオフ

クライアント・アプリケーションには、トランザクション処理を行う前に BEA Tuxedo 環境にログオンしておく必要があります。Jolt クラス・ライブラリには、BEA Tuxedo システムとの接続を確立するための JoltSessionAttributes クラスと JoltSession クラスが用意されています。

JoltSessionAttributes クラスには、さまざまなプロパティのほか、Jolt および BEA Tuxedo システムへの接続プロパティが格納されます。接続を確立するには、クライアント・アプリケーション側で JoltSession クラスのインスタンスを作成する必要があります。このインスタンスが JoltSession オブジェクトです。開発者が Jolt セッションおよび BEA Tuxedo オブジェクトをインスタンス化すると、Jolt および BEA Tuxedo のログオン機能が有効になります。endSession メソッドを呼び出すと、セッションは終了し、ユーザのログオフが可能になります。

同期型のサービス呼び出し

要求や応答などのトランザクションは、JoltRemoteService オブジェクト (JoltRemoteService クラスのインスタンス) を使用して処理されます 。各 JoltRemoteService オブジェクトは、エクスポートされた BEA Tuxedo の要求/応答サービスを参照します。JoltRemoteService オブジェクトを使用する前には、サービス名と JoltSession オブジェクトを指定して、JoltRemoteService オブジェクトをインスタンス化しておく必要があります。

JoltRemoteService オブジェクトを使用するには、次の手順に従います。

効率を高めるため、Jolt では入力パラメータ・オブジェクトはコピーされません。オブジェクトへの参照 (文字列とバイト配列) だけが保存されます。JoltRemoteService オブジェクトは、状態を持つオブジェクトです。そのため、このオブジェクトの入力パラメータとリクエスト属性は、オブジェクトの寿命がある限り維持されます。JoltRemoteService オブジェクトを再利用する前に、clear() メソッドを使用して、属性や入力パラメータをリセットできます。

トランザクションの開始、コミット、およびロールバック

Jolt では、トランザクションは JoltTransaction クラスのオブジェクトとして表されます。トランザクションは、トランザクション・オブジェクトがインスタンス化されると開始されます。次に示すように、トランザクション・オブジェクトの作成時には、タイムアウト値と JoltSession オブジェクトのパラメータが設定されます。

trans = new JoltTransaction(timeout, session)

Jolt では、トランザクションに関与するすべてのサービスに対して明示的なトランザクション・モデルを使用します。トランザクション・サービスを呼び出すには、JoltTransaction オブジェクトがパラメータとして必要です。また、サービスとトランザクションが同じセッションに属していることも必要です。Jolt では、同じセッションにバインドされていないサービスとトランザクションを使用することはできません。

例では、ユーザ定義された 2 つの BEA Tuxedo サービス (WITHDRAWAL と DEPOSIT) をバインドして、TRANSFER トランザクションを擬似的に実行します。WITHDRAWAL 操作が失敗した場合は、ロールバックが実行されます。それ以外の場合は DEPOSIT が実行され、commit によりトランザクションが完了します。

次のリストは、Jolt クラスを使用してファンドを転送する簡単なアプリケーションの例です。

Jolt のファンド転送の例 (SimXfer.java)

/* Copyright 1999 BEA Systems, Inc. All Rights Reserved */　
import bea.jolt.*;　
public class SimXfer　
{　
    public static void main (String[] args)　
    {　
        JoltSession session;　
        JoltSessionAttributes sattr;　
        JoltRemoteService withdrawal;　
        JoltRemoteService deposit;　
        JoltTransaction trans;　
        String userName=null;　
        String userPassword=null;　
        String appPassword=null;　
        String userRole="myapp";　

        sattr = new JoltSessionAttributes();　
        sattr.setString(sattr.APPADDRESS, "//bluefish:8501");　

        switch (sattr.checkAuthenticationLevel())		 　
        {　
        case JoltSessionAttributes.NOAUTH:　
            System.out.println("NOAUTH¥n");　
            break;　
        case JoltSessionAttributes.APPASSWORD:　
            appPassword = "appPassword";　
            break;　
        case JoltSessionAttributes.USRPASSWORD:　
             userName = "myname"; 　
            userPassword = "mysecret";　
            appPassword = "appPassword";　
            break;　
        }　
        sattr.setInt(sattr.IDLETIMEOUT, 300);　
        session = new JoltSession(sattr, userName, userRole,　
        userPassword, appPassword);　
        // 転送をシミュレートする。　
        withdrawal = new JoltRemoteService("WITHDRAWAL", session);　
        deposit = new JoltRemoteService("DEPOSIT", session);　

        withdrawal.addInt("ACCOUNT_ID", 100000);　
        withdrawal.addString("SAMOUNT", "100.00");　

        // トランザクションの開始。タイムアウトは 5 秒
        trans = new JoltTransaction(5, session);　
        try　
        {　
            withdrawal.call(trans);　
        }　

        catch (ApplicationException e)　
        {　
            e.printStackTrace();　
            // このサービスでは STATLIN フィールドを
            // クライアント・アプリケーションのエラー報告に使用する。
            System.err.println(withdrawal.getStringDef("STATLIN","NO 　
            STATLIN"));　
            System.exit(1);　
        }　

        String wbal = withdrawal.getStringDef("SBALANCE", "$-1.0");　

        // 文字列を浮動小数に変換する前に "$" 記号を削除する。
        float w = Float.valueOf(wbal.substring(1)).floatValue();　
        if (w < 0.0)　
        {　
            System.err.println("Insufficient funds");　
            trans.rollback();　
            System.exit(1);　
        }　
        else            // ファンドの預け入れ/転送をする。
        {　
            deposit.addInt("ACCOUNT_ID", 100001);　
            deposit.addString("SAMOUNT", "100.00");　

            deposit.call(trans);　
            String dbal = deposit.getStringDef("SBALANCE", "-1.0");　
            trans.commit();　

            System.out.println("Successful withdrawal");　
            System.out.println("New balance is:" + wbal);　

            System.out.println("Successful deposit");　
            System.out.println("New balance is:" + dbal);　
        }　

        session.endSession();　
        System.exit(0);　
        } // end main　
    } // end SimXfer