org.apache.camel.rx.support
Class ObserverSender<T>
java.lang.Object
org.apache.camel.rx.support.ObserverSender<T>
- All Implemented Interfaces:
- rx.Observer<T>
public class ObserverSender<T>
- extends Object
- implements rx.Observer<T>
An Observer
which sends events to a given Endpoint
Constructor Summary |
ObserverSender(org.apache.camel.Endpoint endpoint)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ObserverSender
public ObserverSender(org.apache.camel.Endpoint endpoint)
throws Exception
- Throws:
Exception
onCompleted
public void onCompleted()
- Specified by:
onCompleted
in interface rx.Observer<T>
onError
public void onError(Throwable e)
- Specified by:
onError
in interface rx.Observer<T>
onNext
public void onNext(T o)
- Specified by:
onNext
in interface rx.Observer<T>
send
protected void send(org.apache.camel.Exchange exchange)
Apache Camel