public abstract class ObservableProcessor<T>
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.Processor
Processor
which provides access to an Observable
so that the messages can be processed using the RX Java APIModifier | Constructor and Description |
---|---|
protected |
ObservableProcessor(rx.functions.Func1<org.apache.camel.Exchange,T> func) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
configure(rx.Observable<T> observable)
Provides the configuration hook so that derived classes can process the observable
to use whatever RX methods they wish to process the incoming events
|
protected void |
doStart() |
protected void |
doStop() |
rx.Observable<T> |
getObservable()
Returns the
Observable for this Processor so that the messages that are received
can be processed using the RX Java API |
void |
process(org.apache.camel.Exchange exchange) |
protected ObservableProcessor(rx.functions.Func1<org.apache.camel.Exchange,T> func)
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
public rx.Observable<T> getObservable()
Observable
for this Processor
so that the messages that are received
can be processed using the RX Java APIprotected abstract void configure(rx.Observable<T> observable)
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
Apache Camel