org.openkilda.wfm.kafka.CustomNamedSubscription Class Reference

Inheritance diagram for org.openkilda.wfm.kafka.CustomNamedSubscription:

Public Member Functions
	CustomNamedSubscription (Collection< String > topics)
	CustomNamedSubscription (String... topics)
String	getTopicsString ()

Detailed Description

Custom implementation of storm's NamedSubscription with fix of incorrect topic names.

Definition at line 11 of file CustomNamedSubscription.java.

Constructor & Destructor Documentation

CustomNamedSubscription() [1/2]

org.openkilda.wfm.kafka.CustomNamedSubscription.CustomNamedSubscription

(

Collection< String >

topics

)

Definition at line 13 of file CustomNamedSubscription.java.

CustomNamedSubscription() [2/2]

org.openkilda.wfm.kafka.CustomNamedSubscription.CustomNamedSubscription

(

String...

topics

)

Definition at line 17 of file CustomNamedSubscription.java.

Member Function Documentation

getTopicsString()

String org.openkilda.wfm.kafka.CustomNamedSubscription.getTopicsString

(

)

Definition at line 22 of file CustomNamedSubscription.java.

---

The documentation for this class was generated from the following file:

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/wfm/src/main/java/org/openkilda/wfm/kafka/CustomNamedSubscription.java