Guava EventBus Component

+

Available since Camel 2.10.0

+

The Google Guava EventBus allows publish-subscribe-style communication between components without requiring the components to explicitly register with one another (and thus be aware of each other). The guava-eventbus: component provides integration bridge between Camel and Google Guava EventBus infrastructure. With the latter component, messages exchanged with the Guava EventBus can be transparently forwarded to the Camel routes. EventBus component allows also to route body of Camel exchanges to the Guava EventBus.

Maven users will need to add the following dependency to their pom.xml for this component:

Modified: websites/production/camel/content/jgroups.html ============================================================================== --- websites/production/camel/content/jgroups.html (original) +++ websites/production/camel/content/jgroups.html Sun Oct 14 02:20:07 2012 @@ -77,6 +77,8 @@

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:

@@ -103,47 +105,28 @@ jgroups:clusterName[?options]

Options

-

Name	Default Value	Description
`eventClass`	`null`	Camel 2.10: If used on the consumer side of the route, will filter events received from the `EventBus` to the instances of the class and superclasses of `eventClass`. Null value of this option is equal to setting it to the `java.lang.Object` i.e. the consumer will capture all messages incoming to the event bus.

+

Name	Default Value	Description
`channelProperties`	`null`	Camel 2.10.0: Specifies configuration properties of the JChannel used by the endpoint.

Usage

-

Using guava-eventbus component on the consumer side of the route will capture messages sent to the Guava EventBus and forward them to the Camel route. Guava EventBus consumer processes incoming messages asynchronously.

+

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.

-SimpleRegistry registry = new SimpleRegistry();
-EventBus eventBus = new EventBus();
-registry.put("busName", eventBus);
-CamelContext camel = new DefaultCamelContext(registry);
-
-from("guava-eventbus:busName").to("seda:queue");
-
-eventBus.post("Send me to the SEDA queue.");
+// Capture messages from cluster named
+// 'clusterName' and send them to Camel route.
+from("jgroups:clusterName").to("seda:queue");

-

Using guava-eventbus component on the producer side of the route will forward body of the Camel exchanges to the Guava EventBus instance.

+

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.

-SimpleRegistry registry = new SimpleRegistry();
-EventBus eventBus = new EventBus();
-registry.put("busName", eventBus);
-CamelContext camel = new DefaultCamelContext(registry);
-
-from("direct:start").to("guava-eventbus:busName");
-
-ProducerTemplate producerTemplate = camel.createProducerTemplate();
-producer.sendBody("direct:start", "Send me to the Guava EventBus.");
-
-eventBus.register(new Object(){
-  @Subscribe
-  public void messageHander(String message) {
-    System.out.println("Message received from the Camel: " + message);
-  }
-});
+// Send message to the cluster named 'clusterName'
+from("direct:start").to("jgroups:clusterName");

Modified: websites/production/camel/content/transport.html ============================================================================== --- websites/production/camel/content/transport.html (original) +++ websites/production/camel/content/transport.html Sun Oct 14 02:20:07 2012 @@ -741,7 +741,12 @@ esper:name

 hibernate://entityName

-