returns an rx.observable for the messages with their payload converted to the given typeto allow the messages sent on the endpoint to be processed using reactive extensions concode_field_sep CamelContext camelContext concode_field_sep Endpoint endpoint concode_elem_sep void sendTo concode_elem_sep void sendTo concode_elem_sep Observable<Exchange> from concode_elem_sep Observable<Exchange> from concode_elem_sep CamelOperator to concode_elem_sep CamelOperator to concode_elem_sep Observable<T> createEndpointObservable concode_elem_sep Observable<Exchange> createEndpointObservable concode_elem_sep CamelContext getCamelContext
Observable < T > function ( String arg0 , final Class < T > arg1 ) { return toObservable ( endpoint ( arg0 ) , arg1 ) ; }