Versions Compared

Old Version 2

changes.mady.by.user James Strachan

Saved on

compared with

New Version 3

changes.mady.by.user James Strachan

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

You can then create an Observable<Message> from any endpoint using the ReactiveCamel helper class.

Code Block
java
java
import org.apache.camel.rx.*;

ReactiveCamel rx = new ReactiveCamel(camelContext);
Observable<Message> observable = rx.toObservable("activemq:MyMessages");

// we can now call filter/map/concat etc
filtered = observable.filter(m -> m.getHeader("foo") != null);