Package org.opennms.core.ipc.sink.camel.server

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CamelMessageConsumerManager

public CamelMessageConsumerManager(org.apache.camel.CamelContext context,
                                   com.codahale.metrics.MetricRegistry metricRegistry)
                            throws Exception

Throws:

Exception

CamelMessageConsumerManager

public CamelMessageConsumerManager(org.apache.camel.CamelContext context,
                                   Identity identity,
                                   TracerRegistry tracerRegistry,
                                   com.codahale.metrics.MetricRegistry metricRegistry)
                            throws Exception

Throws:

Exception

Method Detail

startConsumingForModule

protected void startConsumingForModule(SinkModule<?,Message> module)
                                throws Exception

Specified by:

startConsumingForModule in class AbstractMessageConsumerManager

Throws:

Exception

stopConsumingForModule

protected void stopConsumingForModule(SinkModule<?,Message> module)
                               throws Exception

Specified by:

stopConsumingForModule in class AbstractMessageConsumerManager

Throws:

Exception

setTracerRegistry

public void setTracerRegistry(TracerRegistry tracerRegistry)

setIdentity

public void setIdentity(Identity identity)

start

public void start()

shutdown

public void shutdown()