173.3. Headers

Expand

标头	常数	自版本开始	描述
`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.Address` 实例提取于被使用的消息的 `org.jgroups.Message`.getSrc （）方法。producer ：自定义源 `org.jgroups.Address` 要发送的消息。
`JGROUPS_DEST`	`JGroupsEndpoint.`HEADER_JGROUPS_DEST	2.10.0	consumer ： `org.jgroups.Address` 实例提取于被使用的消息的 `org.jgroups.Message`.getDest （）方法。producer ：自定义目标 `org.jgroups.Address` 要发送的消息。
`JGROUPS_CHANNEL_ADDRESS`	`JGroupsEndpoint.`HEADER_JGROUPS_CHANNEL_ADDRESS	2.13.0	与端点关联的频道的地址(`org.jgroups.Address`)。

# usage

路由使用者端使用 jgroups 组件将捕获与端点关联的 JChannel 接收的消息，并将其转发到 Camel 路由。JGroups 消费者异步处理传入的消息。

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

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

Copy to Clipboard

Toggle word wrap

在路由的制作者端使用 jgroups 组件将 Camel 交换的正文转发到端点管理的 JChannel 实例。

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

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

Copy to Clipboard

Toggle word wrap

返回顶部