174.7. 例子

174.7.1. 将(收发)消息发送到 (来自)JGroups 集群

为了发送消息到 JGroups 集群使用制作者端点,就如下方代码片段中所示:

from("direct:start").to("jgroups:myCluster");
...
producerTemplate.sendBody("direct:start", "msg")

要接收来自上述代码片段的消息(在相同或其他物理机器上)侦听来自给定集群的消息,如下代码片段所示。

mockEndpoint.setExpectedMessageCount(1);
mockEndpoint.message(0).body().isEqualTo("msg");
...
from("jgroups:myCluster").to("mock:messagesFromTheCluster");
...
mockEndpoint.assertIsSatisfied();