You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Claus Ibsen (JIRA)" <ji...@apache.org> on 2014/09/17 14:49:34 UTC

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

     [ 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.11.5)
                   2.15.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
>            Reporter: james strachan
>             Fix For: 2.15.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)