org.apache.camel.rx
Class ObservableMessage

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.rx.support.ObservableProcessor<org.apache.camel.Message>
          extended by org.apache.camel.rx.ObservableMessage
All Implemented Interfaces:
org.apache.camel.Processor, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public abstract class ObservableMessage
extends ObservableProcessor<org.apache.camel.Message>

A base class for a Processor which allows you to process messages using an by implementing the abstract ObservableProcessor.configure(rx.Observable) method.


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
ObservableMessage()
           
 
Method Summary
 
Methods inherited from class org.apache.camel.rx.support.ObservableProcessor
configure, doStart, doStop, getObservable, process
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ObservableMessage

public ObservableMessage()


Apache Camel