aboutsummaryrefslogtreecommitdiffstats
path: root/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactory.java
diff options
context:
space:
mode:
Diffstat (limited to 'policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactory.java')
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactory.java27
1 files changed, 14 insertions, 13 deletions
diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactory.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactory.java
index ee1672d7..adf79706 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactory.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactory.java
@@ -31,12 +31,12 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Noop Topic Sink Factory
+ * Noop Topic Sink Factory.
*/
public interface NoopTopicSinkFactory {
/**
- * Creates noop topic sinks based on properties files
+ * Creates noop topic sinks based on properties files.
*
* @param properties Properties containing initialization values
*
@@ -46,7 +46,7 @@ public interface NoopTopicSinkFactory {
public List<NoopTopicSink> build(Properties properties);
/**
- * builds a noop sink
+ * builds a noop sink.
*
* @param servers list of servers
* @param topic topic name
@@ -57,7 +57,7 @@ public interface NoopTopicSinkFactory {
public NoopTopicSink build(List<String> servers, String topic, boolean managed);
/**
- * Destroys a sink based on the topic
+ * Destroys a sink based on the topic.
*
* @param topic topic name
* @throws IllegalArgumentException if invalid parameters are present
@@ -65,7 +65,12 @@ public interface NoopTopicSinkFactory {
public void destroy(String topic);
/**
- * gets a sink based on topic name
+ * Destroys all sinks.
+ */
+ public void destroy();
+
+ /**
+ * gets a sink based on topic name.
*
* @param topic the topic name
*
@@ -76,34 +81,30 @@ public interface NoopTopicSinkFactory {
public NoopTopicSink get(String topic);
/**
- * Provides a snapshot of the UEB Topic Writers
+ * Provides a snapshot of the UEB Topic Writers.
*
* @return a list of the UEB Topic Writers
*/
public List<NoopTopicSink> inventory();
- /**
- * Destroys all sinks
- */
- public void destroy();
}
/* ------------- implementation ----------------- */
/**
- * Factory of noop sinks
+ * Factory of noop sinks.
*/
class IndexedNoopTopicSinkFactory implements NoopTopicSinkFactory {
private static final String MISSING_TOPIC = "A topic must be provided";
/**
- * Logger
+ * Logger.
*/
private static Logger logger = LoggerFactory.getLogger(IndexedUebTopicSinkFactory.class);
/**
- * noop topic sinks map
+ * noop topic sinks map.
*/
protected HashMap<String, NoopTopicSink> noopTopicSinks = new HashMap<>();