public class ObserverSender<T> extends Object implements rx.Observer<T>
Observer
which sends events to a given Endpoint
Constructor and Description |
---|
ObserverSender(org.apache.camel.Endpoint endpoint) |
public void onCompleted()
onCompleted
in interface rx.Observer<T>
protected void send(org.apache.camel.Exchange exchange)
Apache Camel