public class ObserverSender<T>
extends org.apache.camel.support.ServiceSupport
implements rx.Observer<T>
Observer
which sends events to a given Endpoint
Constructor and Description |
---|
ObserverSender(org.apache.camel.Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
void |
onCompleted() |
void |
onError(Throwable e) |
void |
onNext(T o) |
protected void |
send(org.apache.camel.Exchange exchange) |
public void onCompleted()
onCompleted
in interface rx.Observer<T>
protected void send(org.apache.camel.Exchange exchange)
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
Apache Camel