public class CamelMessageConsumerManager extends AbstractMessageConsumerManager
SINK_INITIAL_SLEEP_TIME, waitForStartup
LOG_PREFIX
Constructor and Description |
---|
CamelMessageConsumerManager(org.apache.camel.CamelContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
startConsumingForModule(SinkModule<?,Message> module) |
protected void |
stopConsumingForModule(SinkModule<?,Message> module) |
dispatch, getNumConsumerThreads, registerConsumer, unregisterAllConsumers, unregisterConsumer
protected void startConsumingForModule(SinkModule<?,Message> module) throws Exception
startConsumingForModule
in class AbstractMessageConsumerManager
Exception
protected void stopConsumingForModule(SinkModule<?,Message> module) throws Exception
stopConsumingForModule
in class AbstractMessageConsumerManager
Exception
Copyright © 2017. All rights reserved.