org.apache.camel.component.salesforce.internal.processor
Class AbstractRestProcessor

java.lang.Object
  org.apache.camel.component.salesforce.internal.processor.AbstractSalesforceProcessor
      org.apache.camel.component.salesforce.internal.processor.AbstractRestProcessor

All Implemented Interfaces:

SalesforceProcessor, org.apache.camel.Service

Direct Known Subclasses:

JsonRestProcessor, XmlRestProcessor

public abstract class AbstractRestProcessor
extends AbstractSalesforceProcessor

Field Summary

protected static String

RESPONSE_CLASS

Fields inherited from class org.apache.camel.component.salesforce.internal.processor.AbstractSalesforceProcessor

endpoint, endpointConfigMap, httpClient, IGNORE_BODY, IS_OPTIONAL, log, NOT_OPTIONAL, operationName, session, USE_BODY

Constructor Summary

AbstractRestProcessor(SalesforceEndpoint endpoint)

Method Summary

protected abstract InputStream	getRequestStream(org.apache.camel.Exchange exchange)
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, SalesforceException ex, org.apache.camel.AsyncCallback callback)
void	start()
void	stop()

Methods inherited from class org.apache.camel.component.salesforce.internal.processor.AbstractSalesforceProcessor

getParameter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RESPONSE_CLASS

protected static final String RESPONSE_CLASS

Constructor Detail

AbstractRestProcessor

public AbstractRestProcessor(SalesforceEndpoint endpoint)
                      throws SalesforceException

Throws:

SalesforceException

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

process

public final boolean process(org.apache.camel.Exchange exchange,
                             org.apache.camel.AsyncCallback callback)

Specified by:

process in interface SalesforceProcessor

Specified by:

process in class AbstractSalesforceProcessor

processRequest

protected abstract void processRequest(org.apache.camel.Exchange exchange)
                                throws SalesforceException

Throws:

SalesforceException

getRequestStream

protected abstract InputStream getRequestStream(org.apache.camel.Exchange exchange)
                                         throws SalesforceException

Throws:

SalesforceException

processResponse

protected abstract void processResponse(org.apache.camel.Exchange exchange,
                                        InputStream responseEntity,
                                        SalesforceException ex,
                                        org.apache.camel.AsyncCallback callback)