sends events on the given observable to the given camel endpoint concode_field_sep CamelContext camelContext concode_elem_sep ExecutorService workerPool concode_field_sep Endpoint endpoint concode_elem_sep Observable<Message> toObservable concode_elem_sep Observable<T> toObservable concode_elem_sep Observable<Message> toObservable concode_elem_sep Observable<T> toObservable 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
void function ( Observable < T > arg0 , String arg1 ) { sendTo ( arg0 , endpoint ( arg1 ) ) ; }