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

Class KafkaTwinSubscriber

java.lang.Object

org.opennms.core.ipc.twin.common.AbstractTwinSubscriber

org.opennms.core.ipc.twin.kafka.subscriber.KafkaTwinSubscriber

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TwinSubscriber

public class KafkaTwinSubscriber
extends AbstractTwinSubscriber

Field Summary

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

TAG_TWIN_RPC_REQUEST

Constructor Summary

Constructors

Constructor	Description
KafkaTwinSubscriber(MinionIdentity identity, KafkaConfigProvider kafkaConfigProvider, TracerRegistry tracerRegistry, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
void	close()
void	init()
protected void	sendRpcRequest(TwinRequest twinRequest)

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

accept, getIdentity, getMetrics, getTracer, getTracerRegistry, mapTwinRequestToProto, mapTwinResponseToProto, subscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTwinSubscriber

public KafkaTwinSubscriber(MinionIdentity identity,
                           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

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class AbstractTwinSubscriber

Throws:

java.io.IOException

sendRpcRequest

protected void sendRpcRequest(TwinRequest twinRequest)

Specified by:

sendRpcRequest in class AbstractTwinSubscriber