public class CxfProducer
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.AsyncProcessor
Constructor and Description |
---|
CxfProducer(CxfEndpoint endpoint)
Constructor to create a CxfProducer.
|
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
org.apache.cxf.endpoint.Client |
getClient() |
protected Map<String,Object> |
prepareRequest(org.apache.camel.Exchange camelExchange,
org.apache.cxf.message.Exchange cxfExchange) |
void |
process(org.apache.camel.Exchange camelExchange)
This processor binds Camel exchange to a CXF exchange and
invokes the CXF client.
|
boolean |
process(org.apache.camel.Exchange camelExchange,
org.apache.camel.AsyncCallback callback) |
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 CxfProducer(CxfEndpoint endpoint) throws Exception
endpoint
- a CxfEndpoint that creates this producerException
- any exception thrown during the creation of a
CXF clientprotected 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 boolean process(org.apache.camel.Exchange camelExchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
public void process(org.apache.camel.Exchange camelExchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
protected Map<String,Object> prepareRequest(org.apache.camel.Exchange camelExchange, org.apache.cxf.message.Exchange cxfExchange) throws Exception
Exception
public org.apache.cxf.endpoint.Client getClient()
Apache Camel