public abstract class ObservableMessage extends ObservableProcessor<org.apache.camel.Message>
Processor
which allows you to process
messages using an
by implementing the
abstract ObservableProcessor.configure(rx.Observable)
method.Constructor and Description |
---|
ObservableMessage() |
configure, doStart, doStop, getObservable, process
Apache Camel