ATMI /Qコンポーネントの使用

Oracle Tuxedo /QのC言語プログラミング

ここでは、以下の内容について説明します。

はじめに

ここでは、キューへのメッセージの登録とキューからのメッセージの取出しを行うATMI C言語関数tpenqueue(3c)、tpdequeue(3c)、およびいくつかの補助関数の使用方法について説明します。

前提知識

キュー機能を使用するクライアント・プログラムまたはサーバー・プログラムをコーディングするOracle TUXEDOプログラマには、Oracle Tuxedo ATMIにバインドされたC言語についての知識が必要です。Oracle Tuxedoプログラミングに関する全般的な説明については、『C言語を使用したOracle Tuxedo ATMIアプリケーションのプログラミング』を参照してください。ATMI関数の詳細は、『Oracle Tuxedo ATMI C関数リファレンス』を参照してください。

リクエストの発信元

Oracle Tuxedo /Qのキューにメッセージを登録する呼出しは、アプリケーションに関連付けられているあらゆるクライアント・プロセスまたはサーバー・プロセスから行うことができます。たとえば、次の発信元があります。

デフォルトの場合の注意事項

ここでは、Oracle Tuxedo /Qプログラミングについて、図「キュー・サービスの呼出し」の主に左側部分について説明します。この図では、クライアント(または、クライアントとして機能するプロセス)はtpenqueue(3c)を呼び出し、TMQUEUE(5)サーバーを通して利用できるキュー・スペースを指定して、メッセージをキューに登録しています。クライアントは、その後、TMQUEUEへのtpdequeue(3c)呼出しを介して、応答を取得します。

図「キュー・サービスの呼出し」では、キューに入れられたメッセージが、サーバーTMQFORWARD(5)によってキューから取り出され、処理のためにtpcall(3c)を介してアプリケーション・サーバーに送信されています。tpcall()に対する応答が受信されると、TMQFORWARDは応答メッセージをキューに登録します。TMQFORWARDの主な目的は、キュー・スペースと既存のアプリケーション・サービスとの間にインタフェースを提供することです。そのため、アプリケーションにコードを追加する必要はありません。そのため、ここでは、クライアントとキュー・スペースとの間の処理を中心に説明します。

キュー機能の使い方を簡単に示すサンプルがソフトウェアに提供されています。詳細は、「サンプル・アプリケーション」を参照してください。

メッセージのキューへの登録

次は、tpenqueue()の構文です。

#include <atmi.h>
int tpenqueue(char *qspace, char *qname, TPQCTL *ctl,
     char *data, long len, long flags)

tpenqueue()が呼び出されると、qspaceで識別されるキュー・スペース内のqnameキューにメッセージを格納するようにシステムが指示されます。メッセージはdataが指すバッファ内にあり、その長さはlenで示されます。flagsにビット設定を行うと、システムにtpenqueue()呼出しの処理方法が通知されます。登録されたメッセージおよび応答の処理方法のさらに詳しい情報は、ctlが指すTMQCTL構造体で定義されます。

tpenqueue(3c)の引数

tpenqueue(3c)の処理を制御するいくつかの重要な引数があります。その一部について、以下に説明します。

tpenqueue(): qspace引数

qspaceは、管理者によってすでに作成されたキュー・スペースを識別します。サーバーが構成ファイルのSERVERSセクションで定義されている場合、そのサーバーが提供するサービス名は、実際のキュー・スペース名(GROUPSセクションのOPENINFOパラメータの一部として指定されます)の別名になります。たとえば、アプリケーションがサーバーTMQUEUEを使用する場合、qspace引数が指す値は、TMQUEUEが公開するサービス名になります。サービス名の別名が何も定義されていない場合、デフォルトのサービス名はサーバー名TMQUEUEと同じになります。その場合、構成ファイルには次の内容が記述されています。

TMQUEUE
        SRVGRP = QUE1  SRVID = 1
        GRACE = 0  RESTART = Y CONV = N
        CLOPT = "-A"

または

	CLOPT = "-s TMQUEUE"

サーバー・グループQUE1のエントリには、OPENINFOパラメータを使用して、リソース・マネージャ、デバイスのパス名、およびキュー・スペース名を指定します。クライアント・プログラムにおけるqspace引数は、次のように記述されます。

if (tpenqueue("TMQUEUE", "STRING", (TPQCTL *)&qctl,
        (char *)reqstr, 0,0) == -1) {
        Error checking
}

TMQUEUE(5)リファレンス・ページの例では、サーバーを作成して構成ファイルで指定する際に、サービスの別名を指定する方法が示されています。「サンプル・アプリケーション」のサンプル・プログラムでも、サービスの別名が指定されています。

tpenqueue(): qname引数

キュー・スペース内で、キューを使用してサービスを呼び出している場合、メッセージ・キューはリクエストを処理できるアプリケーション・サービスに従って命名されます。qnameは、そのようなアプリケーション・サービスを指すポインタです。それ以外の場合、qnameは、アプリケーション(メッセージをキューに登録したアプリケーション、または別のアプリケーション)によってキューから取り出されるまで、メッセージを格納しておく場所を単に示す名前です。

tpenqueue(): dataおよびlen引数

dataは、処理対象のメッセージが格納されたバッファを指すポインタです。そのバッファは、tpalloc(3c)を呼び出して割り当てられたものであることが必要です。lenは、メッセージの長さを指定します。Oracle Tuxedoのバッファ・タイプには、メッセージの長さを指定する必要がないもの(FMLなど)もあります。その場合、lenは無視されます。dataはNULLにすることもできます。その場合、lenは無視され、メッセージはデータ部分なしでキューに登録されます。

tpenqueue(): flags引数

flagsの値は、tpenqueue()呼出しの処理方法をOracle Tuxedoシステムに通知するために使用されます。次は、有効なフラグです。

TPNOTRAN

TPNOBLOCK

TPNOTIME

TPSIGRSTRT

TPQCTL構造体

tpenqueue()の3番目の引数は、TPQCTL型の構造体へのポインタです。TPQCTL構造体には、アプリケーションで使用されるメンバーとOracle Tuxedoシステムで使用されるメンバーがあり、アプリケーション・プログラムとキュー機能間の両方向でパラメータがやり取りされます。tpenqueue()を呼び出すクライアントは、フラグを設定して、システム側で入力する必要のあるフィールドをマークします。この構造体は、tpdequeue()でも使用され、一部のフィールドは、アプリケーションがこの関数を呼び出すまで使用されません。コードリスト3-1は、この構造体全体を示しています。

#define TMQNAMELEN 127 
#define TMMSGIDLEN 32 
#define TMCORRIDLEN 32

struct tpqctl_t {            /* control parameters to queue primitives */ 
     long flags;             /* indicates which of the values are set */ 
     long deq_time;          /* absolute/relative time for dequeuing */ 
     long priority;          /* enqueue priority */ 
     long diagnostic;        /* indicates reason for failure */ 
     char msgid[TMMSGIDLEN];      /* ID of message before which to queue */ 
     char corrid[TMCORRIDLEN];    /* correlation ID used to identify message */ 
     char replyqueue[TMQNAMELEN+1];   /* queue name for reply message */ 
     char failurequeue[TMQNAMELEN+1]; /* queue name for failure message */ 
     CLIENTID cltid;         /* client identifier for originating client */ 
     long urcode;            /* application user-return code */ 
     long appkey;            /* application authentication client key */ 
     long delivery_qos;      /* delivery quality of service */ 
     long reply_qos;         /* reply message quality of service */ 
     long exp_time;          /* expiration time */ 
}; 
typedef struct tpqctl_t TPQCTL;

以下は、tpenqueue()の入力情報を制御するflagsパラメータの有効なフラグです。

TPNOFLAGS

TPQTOP

TPQBEFOREMSGID

TPQTIME_ABS

TPQTIME_REL

TPQPRIORITY

TPQCORRID

TPQREPLYQ

TPQFAILUREQ

TPQDELIVERYQOS、TPQREPLYQOS

TPQEXPTIME_ABS

TPQEXPTIME_REL

TPQEXPTIME_NONE

また、TPQCTLのurcodeフィールドにユーザー戻りコードを設定することができます。この値は、メッセージをキューから取り出すためにtpdequeue(3c)を呼び出すアプリケーションに返されます。

tpenqueue()からの出力では、次のフィールドがTPQCTL構造体に設定されます。

long flags;            /* indicates which of the values are set */
char msgid[32];        /* ID of enqueued message */
long diagnostic;       /* indicates reason for failure */

tpenqueue()からの出力情報を制御するflagsパラメータの有効なビットの一覧を次に示します。tpenqueue()の呼出し時にこのフラグがオンになっていると、/QサーバーTMQUEUE(5)は、構造体の対応する要素にメッセージ識別子を挿入します。tpenqueue()の呼出し時にこのフラグ・ビットをオフにしていると、TMQUEUE()によって構造体の関連要素にメッセージ識別子は設定されません。

TPQMSGID

制御構造体の残りのメンバーは、tpenqueue()への入力に使用されません。

tpenqueue()の呼出しが異常終了してtperrno(5)にTPEDIAGNOSTICが設定された場合、失敗の原因を示す値がctl->diagnosticに返されます。使用できる値は次のとおりです。

[QMEINVAL]

[QMEBADRMID]

[QMENOTOPEN]

[QMETRAN]

[QMEBADMSGID]

[QMESYSTEM]

[QMEOS]

[QMEABORTED]

[QMEPROTO]

[QMEBADQUEUE]

[QMENOSPACE]

[QMERELEASE]

[QMESHARE]

キューの順序の無効化

キューの作成時に、管理者がtpenqueue()呼出しでキュー上のメッセージの順序を無効にできるようにした場合、次の2つの方法でこの機能を利用できます。この2つの方法は、相互に排他的です。flagsにTPQTOPを設定すると、メッセージをキューの先頭に置くことができます。または、flagsにTPQBEFOREMSGID、ctl->msgidに既存のメッセージのIDを設定して、メッセージを特定の既存のメッセージの前に置くこともできます。これは、前の呼出しからのメッセージIDがここで使用できるように保存されたことが前提になります。管理者は、キューでサポートされている方法を通知する必要があります。キューは、この2つのいずれかまたは両方を使用できるように、あるいはどちらも使用できないように作成できます。

キューの優先度の無効化

ctl->priorityに値を設定して、メッセージの優先度を指定することができます。この値は、1から100までの範囲でなければなりません。数値が高いほど優先度が高くなります。キューの順序付けパラメータの中にpriorityが含まれていない場合、ここで優先度を設定しても取出しの順序には影響しません。ただし、優先度の値は保持されるので、メッセージがキューから取り出されるときに検査されます。

メッセージの使用可能時間の設定

deq_timeに、絶対時間またはキューへの登録が完了してからの相対時間として、メッセージが処理されるまで時間を指定できます。flagsに、TPQTIME_ABSまたはTPQTIME_RELのいずれかを設定して、値の処理方法を指定できます。キューは、timeを順序付けの基準として作成することができます。その場合、メッセージは使用可能時間によって順序付けされます。

Oracle Tuxedo /Qには、gp_mktime(3c)関数が提供されています。この関数は、tm構造体の日付と時刻を1970年1月1日から経過した秒数に変換します。time(2)およびmktime(3C)関数をgp_mktime(3c)の代わりに使用することもできます。値は、time_t型(typedef'dで指定されたlong型)で返されます。キューからメッセージが取り出される絶対時間を設定するには、次の手順に従います。ここでは、2001年12月9日正午12:00を使用します。

キューからメッセージを取り出す相対時間、たとえば、キューへの登録操作が完了してからnnn秒などを指定する場合、deq_timeに秒数を指定し、flagsにTPQTIME_RELを設定します。

tpenqueue()とトランザクション

tpenqueue()の呼出し側がトランザクション・モードにある場合に、TPNOTRANが設定されていないと、キューへの登録は呼出し側のトランザクション内で行われます。呼出し側は、tpenqueue()が成功したか失敗したかによって、メッセージがキューに登録されたかどうかを判断できます。呼出しが正常に行われると、メッセージがキューに登録されたことが保証されます。呼出しが失敗すると、メッセージがキューに登録された部分も含めて、トランザクションがロールバックされます。

tpenqueue()の呼出し側がトランザクション・モードにない場合、またはTPNOTRANが設定されている場合、メッセージは呼出し側のトランザクションとは別のトランザクションでキューに登録されます。tpenqueue()への呼出しが正常な戻り値を返した場合、メッセージがキューに登録されたことが保証されます。tpenqueue()の呼出しが通信エラーまたはタイムアウトによって失敗した場合は、その障害がメッセージ登録の前に発生したのか後に発生したのか、呼出し側には判断できません。

呼出し側がトランザクション・モードにないときにTPNOTRANを指定しても意味がありません。

メッセージのキューからの取出し

次は、tpdequeue()の構文です。

#include <atmi.h>
int tpdequeue(char *qspace, char *qname, TPQCTL *ctl, \
        char **data, long *len, long flags)

この呼出しが行われると、qspaceで識別されるキュー・スペース内のqnameキューからメッセージを取り出すようにシステムが指示されます。メッセージは、*dataが指すアドレスにあるバッファ(tpalloc(3c)によって割り当てられたもの)に挿入されます。lenはデータの長さを示します。tpdequeue()から返されたlenが0の場合、そのメッセージにはデータ部分がないことを示します。flagsにビット設定を行うと、システムにtpdequeue()呼出しの処理方法が通知されます。ctlが指すTPQCTL構造体には、この呼出しの処理方法についての詳細な情報が記述されます。

tpdequeue(3c)の引数

tpdequeue(3c)の処理を制御するいくつかの重要な引数があります。その一部について、以下に説明します。

tpdequeue(): qspace引数

qspaceは、管理者によってすでに作成されたキュー・スペースを識別します。TMQUEUEサーバーが構成ファイルのSERVERSセクションで定義されている場合、そのサーバーが提供するサービス名は、実際のキュー・スペース名(GROUPSセクションのOPENINFOパラメータの一部として指定されます)の別名になります。たとえば、アプリケーションがサーバーTMQUEUEを使用する場合、qspace引数が指す値は、TMQUEUEが公開するサービス名になります。サービス名の別名が何も定義されていない場合、デフォルトのサービス名はサーバー名TMQUEUEと同じになります。その場合、構成ファイルには次が記述されています。

TMQUEUE
        SRVGRP = QUE1  SRVID = 1
        GRACE = 0  RESTART = Y CONV = N
        CLOPT = "-A"
or
        CLOPT = "-s TMQUEUE"

サーバー・グループQUE1のエントリには、OPENINFOパラメータを使用して、リソース・マネージャ、デバイスのパス名、およびキュー・スペース名を指定します。クライアント・プログラムにおけるqspace引数は、次のように記述されます。

if (tpdequeue("TMQUEUE", "REPLYQ", (TPQCTL *)&qctl,
        (char **)&reqstr, &len,TPNOTIME) == -1) {
        Error checking
}

TMQUEUE(5)リファレンス・ページの例では、サーバーを作成して構成ファイルで指定する際に、サービスの別名を指定する方法が示されています。「サンプル・アプリケーション」のサンプル・プログラムでも、サービスまたはキュー・スペース名の別名が指定されています。

tpdequeue(): qname引数

キュー・スペース内のキュー名は、そのキュー・スペースにアクセスするアプリケーション間で一貫していなければなりません。これは、応答キューでは特に重要です。qnameが応答キューを参照する場合、管理者はほかのキューと同じ方法で応答キュー、そして多くの場合、エラー・キューも作成します。qnameは、メッセージまたは応答を取り出すキューを指すポインタです。

tpdequeue(): dataおよびlen引数

この2つの引数は、tpenqueue()で使用される場合と若干意味が異なります。*dataは、キューから取り出されたメッセージをシステムが格納するバッファのアドレスを指します。tpdequeue()が呼び出された場合に、この値がNULLであることはエラーです。

tpdequeue()が戻ると、lenは取り出されたデータのデータ長情報を持つlong型を指します。0は応答にデータがなかったことを示します。アプリケーションによっては、これは正当で正常な応答です。長さ0の応答を受信した場合でも、それをキューに登録された要求の正常処理を示すために使用できます。バッファがtpdequeue()呼出しの前と比べて変更されているかどうかを確認する場合は、tpdequeue()呼出しの前にデータ長を保存し、それを呼出しが終了した後でlenと比較します。

tpdequeue(): flags引数

flagsの値は、tpdequeue()呼出しの処理方法をOracle Tuxedoシステムに通知するために使用されます。次は、有効なフラグです。

TPNOTRAN

TPNOBLOCK

TPNOTIME

TPNOCHANGE

TPSIGRSTRT

TPQCTL構造体

tpdequeue()の3番目の引数は、TPQCTL型の構造体へのポインタです。TPQCTL構造体には、アプリケーションで使用されるメンバーとOracle Tuxedoシステムで使用されるメンバーがあり、アプリケーション・プログラムとキュー機能間の両方向でパラメータがやり取りされます。tpdequeue()を呼び出すクライアントはフラグを設定して、システムで値が提供されるべきフィールドをマークします。前述のように、この構造体はtpenqueue()でも使用されます。一部のメンバーは、tpenqueue()だけに適用されます。この構造体全体のサンプル・コードは、「tpqctl_t構造体」に示されています。

tpdequeue()への入力では、次のフィールドをTPQCTL構造体に設定します。

long flags;       /* indicates which of the values are set */
char msgid[32];   /* id of message to dequeue */
char corrid[32];  /* correlation identifier of message to dequeue */

次は、tpdequeue()の入力として有効なフラグです。

TPNOFLAGS

TPQGETBYMSGID

TPQGETBYCORRID

TPQWAIT

TPQPEEK

次は、tpdequeue()からの出力情報を制御するflagsパラメータの有効なビットです。どのフラグ・ビットでも、tpdequeue()の呼出し時にオンになっていると、メッセージがキューに登録されたときに提供された値が、構造体の対応するフィールド(「tpqctl_t構造体」を参照)に格納され、そのビットは設定されたままになります。値が使用できない(つまり、メッセージがキューに登録されたときに値が指定されなかった)場合、またはtpdequeue()を呼び出したときにビットが設定されなかった場合、tpdequeue()はフラグがオフの状態で完了します。

TPQPRIORITY

TPQMSGID

TPQCORRID

TPQDELIVERYQOS

TPQREPLYQOS

TPQREPLYQ

TPQFAILUREQ

flagsパラメータの残りのビットは、tpdequeue()が呼び出されるとクリア(0に設定)されます。これには、TPQTOP、TPQBEFOREMSGID、TPQTIME_ABS、TPQTIME_REL、TPQEXPTIME_ABS、TPQEXPTIME_REL、およびTPQEXPTIME_NONEが含まれます。これらのビットは、tpenqueue()の入力情報を制御するflagsパラメータの有効なビットです。

tpdequeue()の呼出しが失敗し、tperrno(5)にTPEDIAGNOSTICが設定された場合は、失敗の原因を示す値がctl->diagnosticに返されます。ctl->diagnosticの有効なコードには、「TPQCTL構造体」に示されているtpenqueue()の値(QMENOSPACEとQMERELEASEを除く)のほかに、次のものがあります。

[QMENOMSG]

[QMEINUSE]

TPQWAITの使用

TPQCTL構造体のflagsにTPQWAITが設定されてtpdequeue()が呼び出された場合に、メッセージをすぐに取り出すことができないと、tpdequeue()が呼出し側に制御を戻す前に、TMQUEUEサーバーはtpdequeue()リクエストに一致するメッセージがキューに到着するのを待ちます。TMQUEUEプロセスは待機中のリクエストを無視し、他のプロセスのリクエストを処理しながら、最初のリクエストの条件が満たされるのを待ちます。TPQGETBYMSGIDやTPQGETBYCORRIDも指定されている場合、サーバーは指定されたメッセージ識別子や相関識別子を持つメッセージをキューから取り出せるようになるまで待ちます。このどちらのフラグも設定されていない場合、サーバーは任意のメッセージがキューに登録されるまで待ちます。呼出し側がトランザクション・モードの場合、サーバーの待機時間は、呼出し側のトランザクション・タイムアウトによって制御されますが、呼出し側がトランザクション・モードでない場合、TMQUEUEサーバーのCLOPTパラメータに指定される-tオプションで制御されます。

TMQUEUEサーバーは、リクエストを処理するアクション・リソースを利用できるかぎり、複数の待機中tpdequeue()リクエストを同時に処理できます。十分なアクション・リソースがキュー・スペースに対して設定されていない場合、tpdequeue()は失敗します。使用しているシステムがこれに該当する場合は、キュー・スペースに対するアクション・リソースの数を増やしてください。

TMQFORWARDサービス使用時のエラー処理

キューからのメッセージの取出しで、エラー処理の最良の方法を考慮する場合、次の2種類のエラーを区別しておきます。

デフォルトでは、メッセージがトランザクション内でキューから取り出され、そのトランザクションがロールバックされるとき(retryパラメータが0より大きい場合は)、メッセージがキューに戻されて、再度取出しと実行が可能になります。一時的な障害が解消されるように(たとえば、データベースのロックを別のトランザクションが解除するように)少し時間をおいてから、メッセージの取出しと実行を再度試みます。通常、再試行の回数に上限を設定することも、アプリケーション不備によってリソースを著しく浪費することを防ぐために有用です。管理者がキューを設定するときに、再試行の回数と遅延時間(秒単位)の両方を指定できます。再試行の回数0は、再試行が行われないことを示します。再試行の回数が上限に達すると、管理者がキュー・スペースに設定するエラー・キューにメッセージが移動されます。エラー・キューが構成されていない場合、再試行回数に達したメッセージは削除されます。エラー・キューのメッセージは管理者が処理する必要があります。このとき、アプリケーションの要件を満たすように発信元への通知方法を検討します。選択されたメッセージ処理方法は、メッセージをキューに登録した発信元プログラムにほとんど透過的です。メッセージは一度正常にキューに登録されると、tpenqueue()のパラメータおよびキューの属性に従って処理されることが実質的には保証されます。メッセージがエラー・キューに移動されたことの通知は、キューのパラメータを適切に調整されたシステムではほとんどありません。

異常終了キュー(通常、キュー・スペースのエラー・キューとは異なります)は、キューに登録された各メッセージと関連付けられます。このキューは、異常終了メッセージを置く場所として、キューにメッセージを登録する呼出しで指定されます。特定のリクエストに対する異常終了メッセージは、アプリケーション生成の相関識別子で識別できます。相関識別子は、キューにメッセージを登録するときに、そのメッセージと関連付けられます。

成功するまで(または事前に定義された回数まで)再試行を繰り返すというデフォルトの動作は、時間が経過すれば解決されるような一時的な障害が失敗の原因であり、メッセージが後から適切に処理される場合は適しています。

障害が一時的なものではない場合もあります。たとえば、存在しないアカウントでの操作をリクエストするメッセージがキューに入れられている場合(アプリケーションも適当な時間に存在していない場合)です。その場合、再試行してリソースを浪費しないようにします。アプリケーション・プログラマまたは管理者が、特定の操作の失敗が一時的ではないと判断した場合、単に再試行回数を0に設定します。ただし、この場合、このようなメッセージが入るキュー・スペースのエラー・キューを継続的にクリアするメカニズム(キューを定期的に読み取るバックグラウンドのクライアントなど)が必要です。また、同じサービスに対する障害でも、一時的なもの(データベース・ロックの競合など)であったり、永続的なもの(アカウントが存在しないなど)であったりする場合が多くあります。

メッセージがTMQFORWARDによって処理される(キューから取り出され、tpcall()を介してアプリケーションに渡される)場合、tpcall()が返す情報には、TPESVCFAILエラーが一時的な障害と永続的な障害のどちらによって生じたものであるかを示すメカニズムはありません。

キューからの取出しをアプリケーションが処理する場合、簡単な解決方法はたとえ操作が失敗しても、そのサービスに対して成功を返すことです。つまり、TPSUCCESSを設定してtpreturnを実行します。これにより、トランザクションはコミット可能になり、メッセージはキューから削除されます。応答メッセージが使用されている場合、サービスから返されるバッファの情報によって操作の失敗を示すことができ、メッセージが応答キューに登録されます。tpreturnのrcode引数も、アプリケーション固有の情報を返すために使用できます。

サービスが失敗し、トランザクションをロールバックする必要がある場合、TMQFORWARDが処理をそれ以上行わずに、2番目のトランザクションを実行してキューからメッセージを削除するかどうかは明確ではありません。デフォルトでは、TMQFORWARDは失敗したサービスに対するメッセージを削除しません。TMQFORWARDのトランザクションはロールバックされ、メッセージはキューに格納されます。TMQFORWARDにコマンドライン・オプションを指定すると、サービスが失敗して0より長い応答メッセージが返された場合に、メッセージがキューから削除されます。メッセージは、2番目のトランザクションで削除されます。この処理を行うには、キューに遅延時間および再試行回数を設定する必要があります。メッセージが失敗したキューに関連付けられている場合、メッセージがキューから削除されたトランザクションと同じトランザクションで、応答データが異常終了キューに登録されます。

TMQFORWARDを通して呼び出されたサービスからの応答をキューから取り出す手順

アプリケーションがキューに登録されたメッセージに対する応答を要求している場合、次の手順に従います。

メッセージの順次処理

メッセージの順次処理は、あるサービスがそのトランザクションがコミットされる前に、連鎖的に次のサービス用にメッセージをキューに登録することによって行われます。最初の発信元のプロセスは、reply_queueに対する一連のtpdequeue()呼出しによって順次処理の進行状況を追跡できます。ただし、各メンバーが同じ相関識別子を使用し、長さ0の応答を返すことが必要です。

また、非請求通知を使用して、順次処理全体が成功したという通知を最初の発信元に返すこともできます。順次処理の最後のトランザクションがtpcommitで終了したことを確認するには、tpdequeue()から戻されたTPQCTL構造体、またはサービスに渡されたTPSVCINFO構造体で渡されるクライアント識別子を使用して、tpnotifyを呼び出す操作を追加します。最初の発信元であるクライアントは、tpsetunsolを呼び出して、使用されている非請求メッセージ・ハンドラを指定しておかなければなりません。

ピア・ツー・ピア通信でのキューの使用

キューへのメッセージの登録およびキューからのメッセージの取出しに関するこれまでの説明では、キューがリクエスト/レスポンスの一形態として使用されていることが暗黙の前提になっていました。メッセージ自体はサービス・リクエストである必要はありません。キュー機能は、あるプロセスから別のプロセスに、サービス・リクエストと同じように効果的にデータを転送できます。アプリケーション間またはクライアント間のこの通信方式は、ピア・ツー・ピア通信と呼ばれます。

使用するアプリケーションが、このような目的でOracle Tuxedo /Qを使用することに適している場合は、管理者に別のキューを作成してもらい、そのキューからメッセージを取り出す独自の受信用プログラムをコーディングします。