第7章 メッセージの構築
概要
メッセージ構築パターンでは、システムを通過するメッセージのさまざまな形式と関数が記述されます。
7.1. 相関識別子
概要
図7.1「相関識別子パターン」 に記載されている 相関識別子 パターンは、非同期メッセージングシステムを使用してリクエストリプライプロトコルを実装する場合に、リクエストメッセージとリプライメッセージを一致させる方法を説明します。リクエストメッセージはリクエストメッセージを識別する一意のトークンである リクエスト ID によって生成されます。リプライメッセージには、一致するリクエスト ID が含まれるトークンである 相関 ID が含まれる必要があります。
Apache Camel は、メッセージでヘッダーを取得または設定することにより、EIP パターンからの相関識別子をサポートします。
ActiveMQ または JMS コンポーネントを使用する場合、相関識別子ヘッダーは JMSCorrelationID
と呼ばれます。独自の相関識別子をメッセージ交換に追加すると、1 つの会話 (またはビジネスプロセス) で複数のメッセージを一緒に関連付けることができます。通常、相関識別子は Apache Camel メッセージヘッダーに格納されます。
一部の EIP パターンでは、サブメッセージがスピンオフされます。この場合、Apache Camel は、ソースエクスチェンジにリンクする Exchange.CORRELATION_ID
キーのあるプロパティーとして相関 ID をエクスチェンジに追加します。たとえば、Splitter、Multicast、Recipient List、および Wire Tap EIP がこれを行います。
図7.1 相関識別子パターン
イベントメッセージ
Camel は、メッセージ で交換パターンをサポートすることにより、エンタープライズ統合パターン からの イベントメッセージ (Event Message) をサポートします。メッセージ を InOnly を設定すると、一方向のイベントメッセージであることを示すことができます。その後、Camel Apache Camel Component Reference は基盤のトランスポートまたはプロトコルを使用してこのパターンを実装します。
多くの Apache Camel Component Reference のデフォルト動作は、JMS、File、または SEDAなどの InOnly です。
明示的な InOnly の指定
デフォルトが InOut であるコンポーネントを使用している場合、pattern プロパティーを使用して、エンドポイントの メッセージ交換パターン を上書きできます。
foo:bar?exchangePattern=InOnly
Camel 2.0 以降では、DSL を使用して メッセージ交換パターン を指定できます。
Fluent Builder (流れるようなビルダー) の使用
from("mq:someQueue"). inOnly(). bean(Foo.class);
または、明示的なパターンでエンドポイントを呼び出すこともできます。
from("mq:someQueue"). inOnly("mq:anotherQueue");
<route> <from uri="mq:someQueue"/> <inOnly uri="bean:foo"/> </route>
<route> <from uri="mq:someQueue"/> <inOnly uri="mq:anotherQueue"/> </route>