Fuse 6 is no longer supported
As of February 2025, Red Hat Fuse 6 is no longer supported. If you are using Fuse 6, please upgrade to Red Hat build of Apache Camel.此内容没有您所选择的语言版本。
Chapter 81. JGroups
JGroups Component 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Available since Camel 2.10.0
JGroups is a toolkit for reliable multicast communication. The jgroups: component provides exchange of messages between Camel infrastructure and JGroups clusters.
Maven users will need to add the following dependency to their
pom.xml
for this component:
Camel on EAP deployment 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
This component is supported by the Camel on EAP (Wildfly Camel) framework, which offers a simplified deployment model on the Red Hat JBoss Enterprise Application Platform (JBoss EAP) container. For details of this model, see chapter "Apache Camel on JBoss EAP" in "Deploying into a Web Server".
URI format 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
jgroups:clusterName[?options]
jgroups:clusterName[?options]
Where clusterName represents the name of the JGroups cluster the component should connect to.
Options 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Name | Default Value | Description |
---|---|---|
channelProperties
|
null
|
*Camel 2.10.0:* Specifies configuration properties of the JChannel used by the endpoint. |
Usage 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
Using
jgroups
component on the consumer side of the route will capture messages received by the JChannel
associated with the endpoint and forward them to the Camel route. JGroups consumer processes incoming messages asynchronously.
// 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");
Using
jgroups
component on the producer side of the route will forward body of the Camel exchanges to the JChannel
instance managed by the endpoint.
// 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");