21.2. Kafka メッセージを送信するイベントの作成
Business Central でビジネスプロセスを作成したら、Kafka メッセージを送信するイベントを作成できます。
イベントは、データオブジェクトを入力データ項目として指定できます。プロセスエンジンは、設定されたトピックでメッセージとしてデータオブジェクトのコンテンツを送信します。
手順
- Business Central でビジネスプロセスが含まれるプロジェクトを開きます。
メッセージ送信イベントに必要なワークアイテムハンドラーを追加します。
-
Settings
Deployments Work Item Handlers タブを選択します。 - Add Work Item Handler をクリックします。
新しい空の行に以下の値を入力します。
-
Name:
Send Task -
Value:
new org.jbpm.bpmn2.handler.SendTaskHandler() -
Resolver type:
MVEL
-
Name:
-
Settings
- メッセージに含まれる必要のあるデータを定義するデータオブジェクトを作成します。データオブジェクトの作成方法は、BPMN モデルを使用したビジネスプロセスの作成 を参照してください。
- ビジネスプロセスを選択し、ビジネスプロセスデザイナーを開きます。
-
messageタイプの中間出力イベントまたは終了イベントを追加します。 - イベントのプロパティーを開きます。
Message フィールドで New を選択し、メッセージの名前を入力します。この名前は、イベントが Kafka メッセージを送信するトピックの名前と同じにする必要があります。同じにしない場合は、KIE Server の
org.kie.server.jbpm-kafka.ext.topics.broker-topic-nameシステムプロパティーに定義する必要があります。org.kie.server.jbpm-kafka.ext.topics.*システムプロパティーを使用してトピック名を定義する方法は、22章プロセスから Kafka メッセージを送受信するための KIE Server の設定 を参照してください。- 入力データ項目を追加します。タイプとして作成したデータオブジェクトを選択します。
- ビジネスプロセスを保存します。
次のステップ
プロセスの実行時に Red Hat AMQ Streams 統合を有効にするには、22章プロセスから Kafka メッセージを送受信するための KIE Server の設定 の説明に従い KIE Server を設定する必要があります。
