org.apache.camel.rx

Class ObservableMessage

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.rx.support.ObservableProcessor<Message>

org.apache.camel.rx.ObservableMessage

All Implemented Interfaces:

Processor, Service, ShutdownableService, StatefulService, SuspendableService

public abstract class ObservableMessage
extends ObservableProcessor<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

Constructors

Constructor and Description
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()