Package org.apache.camel.rx

The Reactive Camel library for working with Reactive Extensions and Camel using RxJava

See:
          Description

Class Summary
ObservableBody<T> A base class for a Processor which allows you to process messages using an < org.apache.camel.Message> by implementing the abstract org.apache.camel.rx.support.ObservableProcessor#configure(rx.Observable) method.
ObservableMessage A base class for a Processor which allows you to process messages using an by implementing the abstract ObservableProcessor.configure(rx.Observable) method.
ReactiveCamel Provides the Reactive Extensions support for Camel via the RxJava library
 

Exception Summary
RuntimeCamelRxException A runtime exception caused by using the Camel RX layer
 

Package org.apache.camel.rx Description

The Reactive Camel library for working with Reactive Extensions and Camel using RxJava



Apache Camel