public class SpringIntegrationConsumer
extends org.apache.camel.impl.DefaultConsumer
implements org.springframework.integration.core.MessageHandler
Constructor and Description |
---|
SpringIntegrationConsumer(SpringIntegrationEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
SpringIntegrationEndpoint |
getEndpoint() |
void |
handleMessage(org.springframework.integration.Message<?> siInMessage) |
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, handleException, handleException, setExceptionHandler, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
public SpringIntegrationConsumer(SpringIntegrationEndpoint endpoint, org.apache.camel.Processor processor)
public SpringIntegrationEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.Consumer
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
public void handleMessage(org.springframework.integration.Message<?> siInMessage)
handleMessage
in interface org.springframework.integration.core.MessageHandler
Apache Camel