|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Class Summary | |
---|---|
EndpointObservable<T> | An Observable Camel Endpoint |
EndpointSubscribeFunc<T> | |
EndpointSubscription<T> | An RX Subscription on a Camel Endpoint |
ExchangeToBodyFunc1<T> | A simple Func1 to convert an Exchange to the given type using the
IN Message 's body |
ExchangeToMessageFunc1 | A simple Func1 to convert an Exchange to its IN Message |
ObservableProcessor<T> | A base class for implementing a Processor which provides access to an Observable
so that the messages can be processed using the RX Java API |
ObserverSender<T> | An Observer which sends events to a given Endpoint |
ProcessorToObserver<T> | A Processor which invokes an underling Observer as messages
arrive using the given function to convert the Exchange to the required
object |
|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |