public class SalesforceConsumer
extends org.apache.camel.impl.DefaultConsumer
Constructor and Description |
---|
SalesforceConsumer(SalesforceEndpoint endpoint,
org.apache.camel.Processor processor,
SubscriptionHelper helper) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
String |
getTopicName() |
void |
handleException(String message,
Throwable t) |
void |
processMessage(org.cometd.bayeux.client.ClientSessionChannel channel,
org.cometd.bayeux.Message message) |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public SalesforceConsumer(SalesforceEndpoint endpoint, org.apache.camel.Processor processor, SubscriptionHelper helper)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
public void processMessage(org.cometd.bayeux.client.ClientSessionChannel channel, org.cometd.bayeux.Message message)
public void handleException(String message, Throwable t)
handleException
in class org.apache.camel.impl.DefaultConsumer
public String getTopicName()
Apache Camel