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

Class KafkaTopicProvider

java.lang.Object

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

public class KafkaTopicProvider
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaTopicProvider()
KafkaTopicProvider(boolean singleTopic)

Method Summary

Modifier and Type	Method	Description
String	getRequestTopicAtLocation(String location, String module)
String	getResponseTopic(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 String getRequestTopicAtLocation(String location,
                                        String module)

getResponseTopic

public String getResponseTopic(String module)