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

Class KafkaMessageConsumerManager

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager

org.opennms.core.ipc.sink.kafka.server.KafkaMessageConsumerManager

All Implemented Interfaces:

MessageConsumerManager, org.springframework.beans.factory.InitializingBean

public class KafkaMessageConsumerManager
extends AbstractMessageConsumerManager
implements org.springframework.beans.factory.InitializingBean

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
KafkaMessageConsumerManager()
KafkaMessageConsumerManager(KafkaConfigProvider configProvider)
KafkaMessageConsumerManager(KafkaConfigProvider configProvider, Identity identity, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
Identity	getIdentity()
com.codahale.metrics.MetricRegistry	getMetricRegistry()
io.opentracing.Tracer	getTracer()
TracerRegistry	getTracerRegistry()
void	setIdentity(Identity identity)
void	setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry)
void	setTracerRegistry(TracerRegistry tracerRegistry)
void	shutdown()
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

KafkaMessageConsumerManager

public KafkaMessageConsumerManager()

KafkaMessageConsumerManager

public KafkaMessageConsumerManager(KafkaConfigProvider configProvider,
                                   Identity identity,
                                   TracerRegistry tracerRegistry,
                                   com.codahale.metrics.MetricRegistry metricRegistry)

KafkaMessageConsumerManager

public KafkaMessageConsumerManager(KafkaConfigProvider configProvider)

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

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

shutdown

public void shutdown()

getIdentity

public Identity getIdentity()

setIdentity

public void setIdentity(Identity identity)

getTracerRegistry

public TracerRegistry getTracerRegistry()

setTracerRegistry

public void setTracerRegistry(TracerRegistry tracerRegistry)

getTracer

public io.opentracing.Tracer getTracer()

getMetricRegistry

public com.codahale.metrics.MetricRegistry getMetricRegistry()

setMetricRegistry

public void setMetricRegistry(com.codahale.metrics.MetricRegistry metricRegistry)