第7章 メッセージの構築
概要
メッセージ構築パターンでは、システムを通過するメッセージのさまざまな形式と関数が記述されます。
7.1. 相関識別子
概要
図7.1「相関識別子パターン」 の 相関識別子 (Correlation Identifier) パターンは 、非同期メッセージングシステムを使用してリクエスト−リプライ型プロトコルを実装する場合にリクエストメッセージとリプライメッセージの照合方法を記述します。リクエストメッセージはリクエストメッセージを識別する一意のトークンである リクエスト 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 は、一方向のイベントメッセージを示すために InOnly に設定できる メッセージ で Exchange パターンをサポートすることにより、エンタープライズ統合パターン からの イベントメッセージ をサポートします。その後、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>