Class CamelMessageConsumerManager
- java.lang.Object
-
- org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager
-
- org.opennms.core.ipc.sink.camel.server.CamelMessageConsumerManager
-
- All Implemented Interfaces:
MessageConsumerManager
public class CamelMessageConsumerManager extends AbstractMessageConsumerManager
Automatically creates routes to consume from the JMS queues.- Author:
- jwhite
-
-
Field Summary
-
Fields inherited from class org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager
SINK_INITIAL_SLEEP_TIME, startupExecutor, waitForStartup
-
Fields inherited from interface org.opennms.core.ipc.sink.api.MessageConsumerManager
LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED
-
-
Constructor Summary
Constructors Constructor Description CamelMessageConsumerManager(org.apache.camel.CamelContext context, com.codahale.metrics.MetricRegistry metricRegistry)
CamelMessageConsumerManager(org.apache.camel.CamelContext context, Identity identity, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
setIdentity(Identity identity)
void
setTracerRegistry(TracerRegistry tracerRegistry)
void
shutdown()
void
start()
protected void
startConsumingForModule(SinkModule<?,Message> module)
protected void
stopConsumingForModule(SinkModule<?,Message> module)
-
Methods inherited from class org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager
dispatch, getNumConsumerThreads, getStartupExecutor, registerConsumer, unregisterAllConsumers, unregisterConsumer
-
-
-
-
Constructor Detail
-
CamelMessageConsumerManager
public CamelMessageConsumerManager(org.apache.camel.CamelContext context, com.codahale.metrics.MetricRegistry metricRegistry) throws java.lang.Exception
- Throws:
java.lang.Exception
-
CamelMessageConsumerManager
public CamelMessageConsumerManager(org.apache.camel.CamelContext context, Identity identity, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-
Method Detail
-
startConsumingForModule
protected void startConsumingForModule(SinkModule<?,Message> module) throws java.lang.Exception
- Specified by:
startConsumingForModule
in classAbstractMessageConsumerManager
- Throws:
java.lang.Exception
-
stopConsumingForModule
protected void stopConsumingForModule(SinkModule<?,Message> module) throws java.lang.Exception
- Specified by:
stopConsumingForModule
in classAbstractMessageConsumerManager
- Throws:
java.lang.Exception
-
setTracerRegistry
public void setTracerRegistry(TracerRegistry tracerRegistry)
-
setIdentity
public void setIdentity(Identity identity)
-
start
public void start()
-
shutdown
public void shutdown()
-
-