org.apache.camel.rx
Class ObservableBody<T>

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.rx.support.ObservableProcessor<T>
          org.apache.camel.rx.ObservableBody<T>

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 ObservableBody<T>
extends ObservableProcessor<T>

A base class for a Processor which allows you to process messages using an < org.apache.camel.Message> by implementing the abstract org.apache.camel.rx.support.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

ObservableBody(Class<T> bodyType)

Method Summary

String

toString()

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, wait, wait, wait

Constructor Detail

ObservableBody

public ObservableBody(Class<T> bodyType)

Method Detail

toString

public String toString()

Overrides:

toString in class Object