public class CxfRsProducer
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.AsyncProcessor
Constructor and Description |
---|
CxfRsProducer(CxfRsEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
protected org.apache.camel.component.cxf.jaxrs.CxfRsProducer.ClientFactoryBeanCache |
getClientFactoryBeanCache() |
protected void |
invokeAsyncHttpClient(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
protected void |
invokeAsyncProxyClient(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
protected void |
invokeHttpClient(org.apache.camel.Exchange exchange) |
protected void |
invokeProxyClient(org.apache.camel.Exchange exchange) |
protected Map<String,String> |
parseResponseHeaders(Object response,
org.apache.camel.Exchange camelExchange) |
protected CxfOperationException |
populateCxfRsProducerException(org.apache.camel.Exchange exchange,
javax.ws.rs.core.Response response,
int responseCode) |
void |
process(org.apache.camel.Exchange exchange) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
protected void |
setupClientHeaders(org.apache.cxf.jaxrs.client.Client client,
org.apache.camel.Exchange exchange) |
protected void |
setupClientMatrix(org.apache.cxf.jaxrs.client.WebClient client,
org.apache.camel.Exchange exchange) |
protected void |
setupClientQueryAndHeaders(org.apache.cxf.jaxrs.client.WebClient client,
org.apache.camel.Exchange exchange) |
createExchange, createExchange, createExchange, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public CxfRsProducer(CxfRsEndpoint endpoint)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
protected void invokeAsyncHttpClient(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback) throws Exception
Exception
protected void invokeAsyncProxyClient(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback) throws Exception
Exception
protected void setupClientQueryAndHeaders(org.apache.cxf.jaxrs.client.WebClient client, org.apache.camel.Exchange exchange) throws Exception
Exception
protected void setupClientMatrix(org.apache.cxf.jaxrs.client.WebClient client, org.apache.camel.Exchange exchange) throws Exception
Exception
protected void setupClientHeaders(org.apache.cxf.jaxrs.client.Client client, org.apache.camel.Exchange exchange) throws Exception
Exception
protected void invokeHttpClient(org.apache.camel.Exchange exchange) throws Exception
Exception
protected void invokeProxyClient(org.apache.camel.Exchange exchange) throws Exception
Exception
protected org.apache.camel.component.cxf.jaxrs.CxfRsProducer.ClientFactoryBeanCache getClientFactoryBeanCache()
protected CxfOperationException populateCxfRsProducerException(org.apache.camel.Exchange exchange, javax.ws.rs.core.Response response, int responseCode)
Apache Camel