returns an rx.observable to allow the messages sent on the endpointto 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 < Message > function ( Endpoint arg0 ) { return toObservable ( arg0 , Message . class ) ; }