Apache camel Reactive(Rxjava2)

Question

我是Apache camel reactive(Rxjava2(的新手。使用ApachecamelReactive寻找一个简单的"Helloworld"可观察的订阅者示例。请帮忙。

非常感谢

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");
} );