public class GrpcConsumer
extends org.apache.camel.impl.DefaultConsumer
Modifier and Type | Field and Description |
---|---|
protected GrpcConfiguration |
configuration |
protected GrpcEndpoint |
endpoint |
Constructor and Description |
---|
GrpcConsumer(GrpcEndpoint endpoint,
org.apache.camel.Processor processor,
GrpcConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
GrpcConfiguration |
getConfiguration() |
protected void |
initializeServer() |
void |
onCompleted(org.apache.camel.Exchange exchange) |
void |
onError(org.apache.camel.Exchange exchange,
Throwable error) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, 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
protected final GrpcConfiguration configuration
protected final GrpcEndpoint endpoint
public GrpcConsumer(GrpcEndpoint endpoint, org.apache.camel.Processor processor, GrpcConfiguration configuration)
public GrpcConfiguration getConfiguration()
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 onCompleted(org.apache.camel.Exchange exchange)
public void onError(org.apache.camel.Exchange exchange, Throwable error)
Apache Camel