public class ReactiveStreamsConsumer
extends org.apache.camel.impl.DefaultConsumer
Constructor and Description |
---|
ReactiveStreamsConsumer(ReactiveStreamsEndpoint endpoint,
org.apache.camel.Processor processor,
CamelReactiveStreamsService service) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
ReactiveStreamsEndpoint |
getEndpoint() |
void |
onComplete() |
void |
onError(Throwable error) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public ReactiveStreamsConsumer(ReactiveStreamsEndpoint endpoint, org.apache.camel.Processor processor, CamelReactiveStreamsService service)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
public void onComplete()
public void onError(Throwable error)
public ReactiveStreamsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
Apache Camel