Реактивный верблюд Apache (Rxjava2)

Question

Я новичок в реактивном верблюде Apache (Rxjava2).Ищите один простой наблюдаемый пример подписчика «Hello world» с Apache Camel Reactive.Пожалуйста, помогите.

Большое спасибо

Answer 1

Вот простой пример, взятый из http://camel.apache.org/rx.html

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

observable.subscribe(msg -> {
   // do something
}, err -> {
   System.out.println("failure");
} );