[
https://issues.apache.org/jira/browse/CAMEL-7832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claus Ibsen updated CAMEL-7832:
-------------------------------
Fix Version/s: (was: 2.16.0)
2.17.0
> create a java 8 demo of RX to show typesafe filtering and transforming of
> messages
> ----------------------------------------------------------------------------------
>
> Key: CAMEL-7832
> URL: https://issues.apache.org/jira/browse/CAMEL-7832
> Project: Camel
> Issue Type: New Feature
> Components: examples
> Reporter: james strachan
> Fix For: 2.17.0
>
>
> 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...
> {code}
> 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");
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
