public class CamelMessageConsumerManager extends AbstractMessageConsumerManager
SINK_INITIAL_SLEEP_TIME, waitForStartup
LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED
Constructor and Description |
---|
CamelMessageConsumerManager(org.apache.camel.CamelContext context,
Identity identity,
TracerRegistry tracerRegistry,
com.codahale.metrics.MetricRegistry metricRegistry) |
CamelMessageConsumerManager(org.apache.camel.CamelContext context,
com.codahale.metrics.MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
setIdentity(Identity identity) |
void |
setTracerRegistry(TracerRegistry tracerRegistry) |
void |
start() |
protected void |
startConsumingForModule(SinkModule<?,Message> module) |
protected void |
stopConsumingForModule(SinkModule<?,Message> module) |
dispatch, getNumConsumerThreads, registerConsumer, unregisterAllConsumers, unregisterConsumer
public CamelMessageConsumerManager(org.apache.camel.CamelContext context, com.codahale.metrics.MetricRegistry metricRegistry) throws Exception
Exception
public CamelMessageConsumerManager(org.apache.camel.CamelContext context, Identity identity, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry) throws Exception
Exception
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
public void setTracerRegistry(TracerRegistry tracerRegistry)
public void setIdentity(Identity identity)
public void start()
Copyright © 2020. All rights reserved.