JMS コネクタの確立

表6-1 プロセスエンジンで使用される JMS 送り先

JMS 送り先	JMS のタイプ	送られる項目
名前 : WLI_BPM_Audit JNDI 名 : com.bea.wli.bpm.Audit	トピック	監査メッセージ。
名前 : WLI_BPM_Error JNDI 名: com.bea.wli.bpm.Error	トピック	エラーメッセージ。詳細については、ワークフロー例外のモニタリングを参照
名前 : WLI_BPM_Event JNDI 名 : com.bea.wli.bpm.Event	キュー	イベント。すべての入力メッセージはメッセージ駆動型 Bean により処理される。メッセージ駆動型 Bean とは、WebLogic JMS メッセージシステム内でメッセージコンシューマとして機能する EJB のことである。標準 JMS メッセージコンシューマと同様に、メッセージ駆動型 Bean はメッセージを JMS キューまたはトピックから受信し、メッセージのコンテンツに基づいてビジネスロジックを実行する。さらに、メッセージ駆動型 Bean は JMS 送り先の並行処理もサポートする。システム管理者は、必要に応じて複数のイベントキューを定義できる（JMS への接続参照）。この場合、システム管理者は複数のイベントキューに対するメッセージ駆動型 Bean の生成に記載のユーティリティを使用して、関連付けられているメッセージ駆動型 Bean も生成する必要があり、アプリケーション開発者は特定のイベントに対する適切な送り先を指定する必要がある。メッセージ配信の保証とメッセージの順次処理の保証に記載のメソッドを使用して、メッセージの配信と順次処理を適切に実行できる。注意: 下位互換性を保つため、TopicRouter Bean は、WebLogic Process Integrator リリース 1.2.1 以前でサポートされている wlpiEvent トピックを宛先とするすべてのメッセージを WLI_BPM_Event キューに自動的に再ルーティングします。
名前 : WLI_BPM_Notify JNDI 名 : com.bea.wli.bpm.Notify	トピック	Worklist 通知。 Worklist クライアントによる表示の動的な更新と、配信された com.bea.wlpi.common.TaskInfo オブジェクトを使用したタスクオブジェクトデータの取得を可能にする。 WLI_BPM_Notify トピックにポスティングされたメッセージに対しては、適切なサブスクライバに確実に配信するために以下のメッセージプロパティを定義する必要がある。 orgId －オーガニゼーションの ID を指定する文字列 assigneeId －割り当て先（ユーザまたはロール）の ID を指定する文字列 role －割り当て先がロールかどうかを指定するブールフラグ（true または false） action －以下のいずれかのアクションがタスクに対して実行されたことを指定する文字列 - assigned －ユーザに割り当てられたタスク - update －タスク状態の変更 - remove －ユーザタスクのリストから削除されるタスク Worklist クライアントは、メッセージをそのプロパティに基づいてフィルタ処理するセレクタを定義できる。セレクタを使用してメッセージをフィルタ処理するコード例については、JMS トピックへの接続例を参照。 JMS の詳細については、次の URL から BEA WebLogic Server ドキュメント内の『WebLogic JMS プログラマーズガイド』を参照 http://edocs.beasys.co.jp/e-docs/wls/docs70/jms/index.html
名前 : WLI_BPM_Timer JNDI 名 : com.bea.wli.bpm.Timer	キュー	タイムプロセッサトリガ（内部使用のみ）
名前 : WLI_BPM_ValidatingEvent JNDI 名 : com.bea.wli.bpm.ValidatingEvent	キュー	DTD またはスキーマ検証を必要とするイベント XML メッセージが DTD またはスキーマを参照する場合は、コンテンツを検証する必要があります。
名前 : WLI_FailedEvent JNDI 名 : com.bea.wli.FailedEvent	キュー	正常に送信されなかったメッセージで、再試行回数の最大値に達したもの。再試行回数の最大値は Redelivery-Limit 属性を使用して JMS 宛先ごとに設定されている。詳細については、次の URL の『BEA WebLogic Server コンフィグレーションリファレンス』にある JMS テンプレート要素の説明を参照 http://edocs.beasys.co.jp/e-docs/wls/docs70/config_xml/index.html 失敗したメッセージを受信した場合は、エントリがログファイルに記録されます。必要に応じて、カスタムイベントハンドラを開発して失敗したメッセージを処理することもできます。

プロセスエンジンで使用される JMS 送り先の表に定義されているいずれかの JMS 送り先に接続するには（および、XML メッセージをポスティングして受信できるようにするには）、WebLogic Server 管理者が各送り先に対して以下の手順を実行する必要があります。

引数	説明
-queue queue_name	メッセージ駆動型 Bean を生成するカスタムキュー名。必須の引数。
-min minimum	順序なしメッセージの処理に割り当てられるメッセージリスナの最低数。順序なしメッセージとは、特定の順序で処理される必要のないメッセージを指す（メッセージの順次処理の保証参照）。minimum によって最大値より小さい整数値を指定する必要がある。この引数は省略可能で、デフォルトでは 0。
-max maximum	順序なしメッセージの処理に割り当てられるメッセージリスナの最大数。maximum によって指定される整数値は 100 以下でかつ指定最小値より大きな整数値を指定する必要がある。この引数は省略可能で、デフォルトでは 5。
-order ordernum	順序付きメッセージの処理に割り当てられるメッセージリスナの数。順序付きメッセージとは、特定の順序で処理される必要のあるメッセージを指す（メッセージの順次処理の保証参照）。ordernum により 31 以下の素数が指定される。この引数は省略可能で、デフォルトでは 0。
-transact	トランザクションが必須であることを示すフラグ。
-validate	キューで受信したすべてのメッセージを XML JMS メッセージ内の DOC-TYPE タグに照らして検証することを指定するフラグ。省略可能な引数。
-timeout seconds	トランザクションのタイムアウト値（秒単位）。この引数のデフォルト値は 30 秒。この値は、transact フラグが設定されていない場合にのみ使用する。transact フラグが設定されている場合は、WebLogic Server トランザクションタイムアウト値が採用される。この値の設定は Administration Console を使用して行うが、デフォルト値は 30 秒になっている。
-help	コマンド解説構文を表示することを指定するフラグ。省略可能な引数。

引数

説明

-queue queue_name

メッセージ駆動型 Bean を生成するカスタムキュー名。

必須の引数。

-min minimum

順序なしメッセージの処理に割り当てられるメッセージリスナの最低数。順序なしメッセージとは、特定の順序で処理される必要のないメッセージを指す（メッセージの順次処理の保証参照）。minimum によって最大値より小さい整数値を指定する必要がある。

この引数は省略可能で、デフォルトでは 0。

-max maximum

順序なしメッセージの処理に割り当てられるメッセージリスナの最大数。maximum によって指定される整数値は 100 以下でかつ指定最小値より大きな整数値を指定する必要がある。

この引数は省略可能で、デフォルトでは 5。

-order ordernum

順序付きメッセージの処理に割り当てられるメッセージリスナの数。順序付きメッセージとは、特定の順序で処理される必要のあるメッセージを指す（メッセージの順次処理の保証参照）。ordernum により 31 以下の素数が指定される。

この引数は省略可能で、デフォルトでは 0。

-transact

トランザクションが必須であることを示すフラグ。

-validate

キューで受信したすべてのメッセージを XML JMS メッセージ内の DOC-TYPE タグに照らして検証することを指定するフラグ。

省略可能な引数。

-timeout seconds

トランザクションのタイムアウト値（秒単位）。この引数のデフォルト値は 30 秒。

この値は、transact フラグが設定されていない場合にのみ使用する。transact フラグが設定されている場合は、WebLogic Server トランザクションタイムアウト値が採用される。この値の設定は Administration Console を使用して行うが、デフォルト値は 30 秒になっている。

-help

コマンド解説構文を表示することを指定するフラグ。

省略可能な引数。

protected static final String JNDI_FACTORY= "weblogic.jndi.WLInitialContextFactory";
protected static final String JMS_FACTORY= "javax.jms.TopicConnectionFactory";
protected static final String NOTIFY_TOPIC="com.bea.wli.bpm.Notify";

try {
Hashtable env = new Hashtable();
env.put(Context.PROVIDER_URL, wlpi.getUrl());
env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
env.put("weblogic.jndi.createIntermediateContexts", "true");

Context ctx = new InitialContext(env);

if (tsubscriber != null) tsubscriber.close();
String selector = "orgId = '" +
wlpi.getWorklist().getActiveOrganization() + "' AND assigneeId = '" +
wlpi.getUserId() + "' AND NOT role" + " AND action = 'assigned'";
tsubscriber = tsession.createSubscriber(topic, selector, false);

import javax.swing.SwingUtilities;
public void onMessage(Message msg) {
String action;
TaskInfo task;
try {
// TaskInfo ペイロードを持つ ObjectMessages
// が該当。
if (!(msg instanceof ObjectMessage))
return;
Object data = ((ObjectMessage)msg).getObject();
if (!(data instanceof TaskInfo))
return;
action = msg.getStringProperty("action");
task = (TaskInfo)data;
} catch (JMSException e) {
e.printStackTrace();
return;
}

if (action.equals("update"))
taskUpdated(task);
else if (action.equals("remove"))
taskDeleted(task);
}

private void taskDeleted(final TaskInfo task) {
SwingUtilities.invokeLater(new Runnable() {
public void run() {
vTasks.remove(task);
int row = vDisplayedTasks.indexOf(task);
if (row != -1) {
vDisplayedTasks.remove(row);
model.fireTableRowsDeleted(row, row);
}
}
});
}