Package org.opennms.core.ipc.twin.kafka.publisher

Class KafkaTwinPublisher

java.lang.Object

org.opennms.core.ipc.twin.common.AbstractTwinPublisher

org.opennms.core.ipc.twin.kafka.publisher.KafkaTwinPublisher

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TwinPublisher

public class KafkaTwinPublisher
extends AbstractTwinPublisher

Nested Class Summary

Nested classes/interfaces inherited from class org.opennms.core.ipc.twin.common.AbstractTwinPublisher

AbstractTwinPublisher.SessionKey

Nested classes/interfaces inherited from interface org.opennms.core.ipc.twin.api.TwinPublisher

TwinPublisher.Session<T>

Field Summary

Fields inherited from class org.opennms.core.ipc.twin.common.AbstractTwinPublisher

objectMapper, TAG_PATCH, TAG_SESSION_ID, TAG_TWIN_RPC, TAG_TWIN_SINK, TAG_VERSION

Constructor Summary

Constructors

Constructor	Description
KafkaTwinPublisher(LocalTwinSubscriber localTwinSubscriber, KafkaConfigProvider kafkaConfigProvider, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)
KafkaTwinPublisher(LocalTwinSubscriber localTwinSubscriber, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	handleSinkUpdate(TwinUpdate sinkUpdate)
void	init()

Methods inherited from class org.opennms.core.ipc.twin.common.AbstractTwinPublisher

addTracingInfo, forEachSession, generateTracingOperationKey, getTracer, getTwin, mapTwinRequestProto, mapTwinResponse, register

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opennms.core.ipc.twin.api.TwinPublisher

register

Constructor Detail

KafkaTwinPublisher

public KafkaTwinPublisher(LocalTwinSubscriber localTwinSubscriber,
                          TracerRegistry tracerRegistry,
                          com.codahale.metrics.MetricRegistry metricRegistry)

KafkaTwinPublisher

public KafkaTwinPublisher(LocalTwinSubscriber localTwinSubscriber,
                          KafkaConfigProvider kafkaConfigProvider,
                          TracerRegistry tracerRegistry,
                          com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

init

public void init()
          throws java.lang.Exception

Throws:

java.lang.Exception

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

handleSinkUpdate

protected void handleSinkUpdate(TwinUpdate sinkUpdate)

Specified by:

handleSinkUpdate in class AbstractTwinPublisher

Parameters:

sinkUpdate - Handle sink Update from @AbstractTwinPublisher.