[CAMEL-7832] create a java 8 demo of RX to show typesafe filtering and transforming of messages

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.18.0
• Component/s: examples
• Estimated Complexity: Unknown
• Assignee: Luca Burgazzoli
• Reporter: James Strachan
• Created: 17/Sep/14 12:47
• Updated: 12/Sep/16 14:29
• Resolved: 12/Sep/16 14:29

Description

Camel RX can already do typesafe processing of messages
http://camel.apache.org/rx.html

it'd be nice to show a demo using Java 8 and lambdas. e.g. like this...

ReactiveCamel rx = new ReactiveCamel(camelContext);
Observable<Order> observable = rx.toObservable("seda:orders", Order.class);
 
// now lets filter and map using Java 8
Observable<String> largeOrderIds = observable.
  filter(order -> order.getAmount() > 100.0).
  map(order -> order.getId());
 
rx.sendTo(observable, "activemq:MyQueue");

Issue Links

• is related to: CAMEL-7831 create a java8 only demo showing how to use lambda expressions for Predicate / Expression inside the Java DSL (using Message as a typesafe parameter)
• is related to: CAMEL-7833 create an extension of the RX Observable<T> to add more of the Camel DSL in there (e.g. to() or to go back to the general camel DSL)