Red Hat Training

A Red Hat training course is available for Red Hat Fuse

165.3. ヘッダー

ヘッダー定数以降のバージョン説明

JGROUPS_ORIGINAL_MESSAGE

JGroupsEndpoint.HEADER_JGROUPS_ORIGINAL_MESSAGE

2.13.0

消費されたメッセージの本文が抽出された元の org.jgroups.Message インスタンス。

JGROUPS_SRC

`JGroupsEndpoint.`HEADER_JGROUPS_SRC

2.10.0

Consumer : 消費されたメッセージの org.jgroups.Message.getSrc()メソッドによって展開された org.jgroups.Address インスタンス。Producer : 送信されるメッセージのカスタムソース org.jgroups.Address

JGROUPS_DEST

`JGroupsEndpoint.`HEADER_JGROUPS_DEST

2.10.0

Consumer : 消費されたメッセージの org.jgroups.Message.getDest() メソッドによって抽出された org.jgroups.Address インスタンス。Producer : 送信されるメッセージのカスタム宛先 org.jgroups.Address

JGROUPS_CHANNEL_ADDRESS

`JGroupsEndpoint.`HEADER_JGROUPS_CHANNEL_ADDRESS

2.13.0

エンドポイントに関連付けられたチャネルのアドレス (org.jgroups.Address)。

  # 用途

ルートのコンシューマー側で jgroups コンポーネントを使用すると、エンドポイントに関連付けられた JChannel によって受信されたメッセージがキャプチャーされ、Camel ルートに転送されます。JGroups コンシューマーは、入力メッセージを 非同期的に 処理します。

// Capture messages from cluster named
// 'clusterName' and send them to Camel route.
from("jgroups:clusterName").to("seda:queue");

ルートのプロデューサー側で jgroups コンポーネントを使用すると、Camel エクスチェンジのボディーがエンドポイントによって管理される JChannel インスタンスに転送されます。

// Send message to the cluster named 'clusterName'
from("direct:start").to("jgroups:clusterName");