静的なサブスクリプションの suppressible 属性を使用する

メッセージ ブローカ チャネルの静的なサブスクリプションは、ビジネス プロセスでサブスクリプションの suppressible 属性を設定することで「抑制可能なもの」として指定できます。suppressible の有効な値は、true および false (デフォルト) です。suppressible を true に設定すると、動的サブスクリプションが優先され、静的サブスクリプションが使用されないように指定されます。つまり、メッセージ ブローカ チャネルの特定のメッセージによって新しいビジネス プロセスが開始されないようにできます。代わりに、すでに実行されているビジネス プロセスで、動的サブスクリプションによってメッセージが受信されます。

一般的に suppressible 属性は、同じビジネス プロセスに対して同じグループ ID を持つメッセージのルーティングを設計するために使用されます。理想的なシナリオは、JMS イベント ジェネレータによって処理されるメッセージの JMS プロパティをグループ ID として使用することです。

このようなシナリオの設計には、以下の節で説明するように、ビジネス プロセスとイベント ジェネレータの設定が必要になります。

• ビジネス プロセスを設定する
• イベント ジェネレータを設定する

ビジネス プロセスを設定する

この例では、JMS イベント ジェネレータによって処理されるメッセージの JMS プロパティをグループ ID として使用し、同じビジネス プロセスに対して同じグループ ID を持つメッセージのルーティングを設計します。

次のコード例は、JMS イベント ジェネレータのプロパティを示します。

<JmsEventGenerator>
 

	<property>
 

		<Name>GROUPID</Name>
 

		<Value>100</Value>
 

	</property>
 

	... 

</JmsEventGenerator>
 

特定のメッセージ ブローカ チャネルで送信された、同じ GROUPID プロパティを持つすべてのメッセージを受信するビジネス プロセスを作成するには

1. メッセージが購読されるメッセージ ブローカ チャネルからメッセージを受信すると開始されるように、ビジネス プロセスを設計します。その方法については、[Subscription] による開始 (同期) を参照してください。

注意 : この例では、/my/orders というチャネルを使用します。

2. suppressible 属性を true に設定します。手順は次のとおりです。
1. ビジネス プロセスが WebLogic Workshop のグラフィカル設計環境で開かれた状態で、[ソース ビュー] タブをクリックし、ソース コードに静的サブスクリプション メソッドを配置します。先頭に次の JPD 注釈が付きます。

@jpd:mb-static-subscription
 

2. 静的サブスクリプション メソッド内の任意の場所をクリックします。プロパティ エディタの mb-static-subscription の下に一連の属性 (suppressible を含む) が表示されます。



3. プロパティ エディタで、suppressible 属性に対して true を選択します。ソース コードの JPD 注釈が更新され、suppressible 属性が含まれるようになります。

@jpd:mb-static-subscription suppressible="true"
 

3. メッセージを受信するようにビジネス プロセスを設計します。
4. メッセージから変数 (myOrderNumber 変数など) に $metadata/property[name='GROUPID'] を抽出します。
5. myOrderNumber 変数をフィルタ値として使用して、/my/orders チャネルを (動的に) サブスクライブします。つまり、上記の手順でデータを変数に抽出するのに使用したものと同じ XPath 式を持つフィルタ式を使用します。

$metadata/property[name='GROUPID']
 

動的サブスクリプションの設計方法については、メッセージ ブローカ サブスクリプション コントロールを参照してください。

6. サブスクリプション コントロールを使用して、同じ GROUPID を持つメッセージの残りを受信するように、ループを設計します。

ループ ロジックの設計方法については、リスト内の項目を反復処理するを参照してください。

注意 : 競合状態を回避するには、手順 1 〜 5 を同期的なメッセージ ブローカ サブスクリプション内で実行する必要があります。同期サブスクリプションの作成方法については、[Subscription] による開始 (同期) を参照してください。

イベント ジェネレータを設定する

この例での抑制可能パターンが正しく機能するには、所定のグループ ID 用のパブリッシャが 1 つ必要になります。所定のグループ ID 用のパブリッシャを 1 つ用意するということは、新しいサブスクライバが動的なサブスクライブを行っているとき (上記の節ビジネス プロセスを設定するの手順 1 〜 5 を参照) にそのパブリッシャが中断されることを意味します。これにより、サブスクリプションの競合状態が回避されます。JMS イベント ジェネレータを使用している場合、1 つのパブリッシャが所定のグループ ID を確実にパブリッシュする方法は 2 種類あります。

• JMS イベント ジェネレータのプール サイズを 1 に設定します。JMS イベント ジェネレータは、メッセージ駆動型 Bean プールとしてパッケージ化されます。

JMS イベント ジェネレータのプール サイズを設定するには、デプロイメント記述子を手動で編集する必要があります。そのためには、WebLogic Workshop 設計コンソールのメニュー バーから使用できる WebLogic Builder ツールを使用します。

[ツール｜WebLogic Server｜WebLogic Builder]

注意 : サブスクライバのプール サイズを制限する必要はありません。

• それぞれに異なるメッセージ セレクタを持ち、それぞれのプール サイズが 1 に設定されている、複数の JMS イベント ジェネレータを作成します。メッセージ セレクタは、グループ ID を JMS イベント ジェネレータにユニークにマップします。つまり、1 つのイベント ジェネレータは、指定されたグループ ID を持つすべてのイベントのパブリッシュを行います。次の図では、GROUPID=101 のメッセージが 1 つの JMS イベント ジェネレータ (JMS EG (選択 1)) によってどのようにパブリッシュされるかが示されています。

下の図で示されたシナリオでは、100 〜 299 の範囲の GROUPID を持つキューが定義されています。一方は 100 〜 199 の範囲の GROUPID を処理し、もう一方は 200 〜 299 の範囲の GROUPID を処理する、2 つの JMS イベント ジェネレータが定義されています。



上記の節 (ビジネス プロセスを設定する) で説明した静的サブスクリプションおよび動的サブスクリプションは、同期的なサブスクリプションによる開始ブロック内にあるので、GROUPID=101 のメッセージをパブリッシュする JMS イベント ジェネレータは、最初のメッセージの配信後、動的サブスクリプションなどのロジックが同期的なサブスクリプションのブロック内で実行されるまでブロックされます。その後、次の GROUPID=101 のメッセージがパブリッシュされます。ビジネス プロセスの静的サブスクリプションに対して suppressible が true に設定されていると、2 番目のメッセージによって新しいビジネス プロセスは開始されません。代わりに、2 番目のメッセージは、最初の GROUPID=101 のメッセージを受信することで開始されたビジネス プロセスで動的サブスクリプションによって受信されます。