public class RestProducer extends DefaultAsyncProducer
logshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
RestProducer(Endpoint endpoint,
Producer producer,
RestConfiguration configuration) |
| Modifier and Type | Method and Description |
|---|---|
protected AsyncProcessor |
createBindingProcessor() |
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
String |
getBindingMode() |
RestEndpoint |
getEndpoint()
Gets the endpoint associated with an object.
|
String |
getOutType() |
Boolean |
getSkipBindingOnErrorCode() |
String |
getType() |
boolean |
isPrepareUriTemplate() |
protected void |
prepareExchange(Exchange exchange) |
boolean |
process(Exchange exchange,
AsyncCallback callback)
Processes the message exchange.
|
void |
setBindingMode(String bindingMode) |
void |
setOutType(String outType) |
void |
setPrepareUriTemplate(boolean prepareUriTemplate)
Whether to prepare the uri template and replace {key} with values from the exchange, and set
as
Exchange.HTTP_URI header with the resolved uri to use instead of uri from endpoint. |
void |
setSkipBindingOnErrorCode(Boolean skipBindingOnErrorCode) |
void |
setType(String type) |
processcreateExchange, createExchange, createExchange, isSingleton, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic RestProducer(Endpoint endpoint, Producer producer, RestConfiguration configuration)
public boolean process(Exchange exchange, AsyncCallback callback)
AsyncProcessorProcessor.process(org.apache.camel.Exchange), but the caller supports having the exchange asynchronously processed.
If there was a failure processing then the caused Exception would be set on the Exchange.exchange - the message exchangecallback - the AsyncCallback will be invoked when the processing of the exchange is completed.
If the exchange is completed synchronously, then the callback is also invoked synchronously.
The callback should therefore be careful of starting recursive loop.public RestEndpoint getEndpoint()
EndpointAwareProducer
or for consuming from for components like Consumer or RoutegetEndpoint in interface EndpointAwaregetEndpoint in class DefaultProducerpublic boolean isPrepareUriTemplate()
public void setPrepareUriTemplate(boolean prepareUriTemplate)
Exchange.HTTP_URI header with the resolved uri to use instead of uri from endpoint.public String getBindingMode()
public void setBindingMode(String bindingMode)
public Boolean getSkipBindingOnErrorCode()
public void setSkipBindingOnErrorCode(Boolean skipBindingOnErrorCode)
public String getOutType()
public void setOutType(String outType)
protected void prepareExchange(Exchange exchange) throws Exception
Exceptionprotected void doStart() throws Exception
ServiceSupportServiceSupport.doStop() for more details.doStart in class DefaultProducerExceptionServiceSupport.doStop()protected void doStop() throws Exception
ServiceSupportServiceSupport.doStop() method when
the service is being stopped. This method will also be invoked
if the service is still in uninitialized state (eg has not
been started). The method is always called to allow the service
to do custom logic when the service is being stopped, such as when
CamelContext is shutting down.doStop in class DefaultProducerExceptionServiceSupport.doStart()protected AsyncProcessor createBindingProcessor() throws Exception
ExceptionApache Camel