co.cask.cdap.messaging

Class MessagingServiceUtils

java.lang.Object

co.cask.cdap.messaging.MessagingServiceUtils

public final class MessagingServiceUtils
extends Object

A util class for TMS.

Method Summary

Modifier and Type	Method and Description
static Set<co.cask.cdap.proto.id.TopicId>	getSystemTopics(CConfiguration cConf, boolean ignoreInvalidTopic) Returns a set of system TopicId as configured by the Constants.MessagingSystem#SYSTEM_TOPICS property.

Methods inherited from class java.lang.Object

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

Method Detail

getSystemTopics

public static Set<co.cask.cdap.proto.id.TopicId> getSystemTopics(CConfiguration cConf,
                                                                 boolean ignoreInvalidTopic)

Returns a set of system TopicId as configured by the Constants.MessagingSystem#SYSTEM_TOPICS property.

Parameters:

cConf - the configuration to get the system topics

ignoreInvalidTopic - if true, invalid topics will be ignored; otherwise exception will be raised

Returns:

a set of valid system TopicId.

Throws:

IllegalArgumentException - if ignoreInvalidTopic is true and there is invalid topic being configured