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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 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
-
afterPropertiesSet
public void afterPropertiesSet() throws java.lang.Exception
- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
- Throws:
java.lang.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)
-
-