|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Observable
given a function which converts
the Exchange
from the Camel consumer to the required type
Observerable
Camel Endpoint
Subscription
on a Camel Endpoint
Func1
to convert an Exchange
to the given type using the
IN Message
's bodyFunc1
to convert an Exchange
to its IN Message
Observable
for this Processor
so that the messages that are received
can be processed using the RX Java API
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.Processor
which allows you to process
messages using an Observable
by implementing the
abstract org.apache.camel.rx.support.ObservableProcessor#configure(rx.Observable
method.Processor
which provides access to an Observable
so that the messages can be processed using the RX Java APIObserver
which sends events to a given Endpoint
Processor
which invokes an underling Observer
as messages
arrive using hte given function to convert the Exchange
to the required
objectObservable
to the given camel endpoint
Observable
to the given camel endpoint
< org.apache.camel.Message >
to allow the messages sent on the endpoint
to be processed using Reactive Extensions
for the messages with their payload converted to the given type
to allow the messages sent on the endpoint
to be processed using Reactive Extensions
< org.apache.camel.Message >
to allow the messages sent on the endpoint
to be processed using Reactive Extensions
for the messages with their payload converted to the given type
to allow the messages sent on the endpoint
to be processed using Reactive Extensions
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |