Package org.opennms.core.ipc.common.kafka

Class KafkaTopicProvider

java.lang.Object

org.opennms.core.ipc.common.kafka.KafkaTopicProvider

public class KafkaTopicProvider
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
KafkaTopicProvider()
KafkaTopicProvider(boolean singleTopic)

Method Summary

Modifier and Type	Method	Description
java.lang.String	getRequestTopicAtLocation(java.lang.String location, java.lang.String module)
java.lang.String	getResponseTopic(java.lang.String module)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTopicProvider

public KafkaTopicProvider(boolean singleTopic)

KafkaTopicProvider

public KafkaTopicProvider()

Method Detail

getRequestTopicAtLocation

public java.lang.String getRequestTopicAtLocation(java.lang.String location,
                                                  java.lang.String module)

getResponseTopic

public java.lang.String getResponseTopic(java.lang.String module)