public abstract class AbstractRestProcessor extends AbstractSalesforceProcessor
Modifier and Type | Field and Description |
---|---|
protected static String |
RESPONSE_CLASS |
endpoint, endpointConfigMap, httpClient, IGNORE_BODY, IS_OPTIONAL, log, NOT_OPTIONAL, operationName, rawPayload, session, USE_BODY
Constructor and Description |
---|
AbstractRestProcessor(SalesforceEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected abstract InputStream |
getRequestStream(org.apache.camel.Exchange exchange) |
protected abstract InputStream |
getRequestStream(org.apache.camel.Message in,
Object object)
Returns
InputStream to serialized form of the given object. |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
protected abstract void |
processRequest(org.apache.camel.Exchange exchange) |
protected abstract void |
processResponse(org.apache.camel.Exchange exchange,
InputStream responseEntity,
Map<String,String> headers,
SalesforceException ex,
org.apache.camel.AsyncCallback callback) |
void |
start() |
void |
stop() |
getParameter, getParameter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
determineHeaders
protected static final String RESPONSE_CLASS
public AbstractRestProcessor(SalesforceEndpoint endpoint) throws SalesforceException
SalesforceException
public final boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface SalesforceProcessor
process
in class AbstractSalesforceProcessor
protected abstract void processRequest(org.apache.camel.Exchange exchange) throws SalesforceException
SalesforceException
protected abstract InputStream getRequestStream(org.apache.camel.Exchange exchange) throws SalesforceException
SalesforceException
protected abstract InputStream getRequestStream(org.apache.camel.Message in, Object object) throws SalesforceException
InputStream
to serialized form of the given object.object
- object to serializeSalesforceException
protected abstract void processResponse(org.apache.camel.Exchange exchange, InputStream responseEntity, Map<String,String> headers, SalesforceException ex, org.apache.camel.AsyncCallback callback)
Apache Camel