Package | Description |
---|---|
org.apache.camel.rx |
The Reactive Camel library for working with Reactive Extensions
and Camel using RxJava
|
Modifier and Type | Class and Description |
---|---|
class |
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. |
class |
ObservableMessage
A base class for a
Processor which allows you to process
messages using an by implementing the
abstract configure(rx.Observable) method. |
Apache Camel