RxJava I/O using camel stream

CamelBlocking.java

public class CamelBlocking {

   public static void main(String[] args) throws InterruptedException {
      CamelContext camelContext = new DefaultCamelContext();
      ReactiveCamel rx = new ReactiveCamel(camelContext);
      Observable<String> observable = rx.toObservable(
            "stream:in?scanStream=true", String.class);
      observable.toBlockingObservable().forEach(new Action1<String>() {
         @Override
         public void call(String m) {
            System.err.println(m);
         }
      });
   }
}