org.apache.camel.rx.support
Class ObserverSender<T>

java.lang.Object
  extended by 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)
           
 
Method Summary
 void onCompleted()
           
 void onError(Throwable e)
           
 void onNext(T o)
           
protected  void send(org.apache.camel.Exchange exchange)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ObserverSender

public ObserverSender(org.apache.camel.Endpoint endpoint)
               throws Exception
Throws:
Exception
Method Detail

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