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
-
-
Constructor Summary
Constructors Constructor Description KafkaTwinSubscriber(MinionIdentity identity, KafkaConfigProvider kafkaConfigProvider)
-
Method Summary
All Methods Instance Methods Concrete Methods 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, mapTwinRequestToProto, mapTwinResponseToProto, subscribe
-
-
-
-
Constructor Detail
-
KafkaTwinSubscriber
public KafkaTwinSubscriber(MinionIdentity identity, KafkaConfigProvider kafkaConfigProvider)
-
-
Method Detail
-
init
public void init()
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classAbstractTwinSubscriber
- Throws:
java.io.IOException
-
sendRpcRequest
protected void sendRpcRequest(TwinRequest twinRequest)
- Specified by:
sendRpcRequest
in classAbstractTwinSubscriber
-
-