Adding NOOP sources support

In addition, Noop* classes have been refactored to
increase code reuse and clean some checkstyle issues.
Additional Junits have been added for existing functionality.

Change-Id: I072f9ff2f415630ac82eca949a8360249f73da86
Issue-ID: POLICY-1397
Signed-off-by: Jorge Hernandez <jorge.hernandez-herrero@att.com>

1 files changed, 0 insertions, 119 deletions

diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/http/server/test/NoopTopicTest.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/http/server/test/NoopTopicTest.java
deleted file mode 100644
index 388524a9..00000000
--- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/http/server/test/NoopTopicTest.java
+++ /dev/null
@@ -1,119 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-endpoints
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.policy.common.endpoints.http.server.test;
-
-import static org.junit.Assert.assertTrue;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
-import org.onap.policy.common.endpoints.event.comm.TopicEndpoint;
-import org.onap.policy.common.endpoints.event.comm.TopicListener;
-import org.onap.policy.common.endpoints.event.comm.TopicSink;
-import org.onap.policy.common.endpoints.event.comm.bus.NoopTopicSink;
-import org.onap.policy.common.endpoints.properties.PolicyEndPointProperties;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * NOOP Endpoint Tests.
- */
-public class NoopTopicTest implements TopicListener {
-
-    /**
-     * Logger.
-     */
-    private static Logger logger = LoggerFactory.getLogger(NoopTopicTest.class);
-
-    private final String topicName = "junit-noop";
-    private final String outMessage = "blah";
-    private String inMessage = null;
-
-    @Test
-    public void testNoopEndpoint() {
-        logger.info("-- testNoopEndpoint() --");
-
-        Properties noopSinkProperties = new Properties();
-        noopSinkProperties.put(PolicyEndPointProperties.PROPERTY_NOOP_SINK_TOPICS, topicName);
-
-        List<? extends TopicSink> noopTopics = TopicEndpoint.manager.addTopicSinks(noopSinkProperties);
-
-        TopicSink sink = NoopTopicSink.factory.get(topicName);
-
-        assertTrue(noopTopics.size() == 1);
-        assertTrue(noopTopics.size() == NoopTopicSink.factory.inventory().size());
-        assertTrue(noopTopics.get(0) == sink);
-        assertTrue(sink == NoopTopicSink.factory.inventory().get(0));
-
-        assertTrue(!sink.isAlive());
-
-        boolean badState = false;
-        try {
-            sink.send(outMessage);
-        } catch (IllegalStateException e) {
-            badState = true;
-        }
-        assertTrue(badState);
-
-        sink.start();
-        assertTrue(sink.isAlive());
-
-        sink.send(outMessage);
-        assertTrue(sink.getRecentEvents().length == 1);
-        assertTrue(sink.getRecentEvents()[0].equals(outMessage));
-        assertTrue(this.inMessage == null);
-
-        sink.register(this);
-        sink.send(this.outMessage);
-        assertTrue(outMessage.equals(this.inMessage));
-        this.inMessage = null;
-
-        sink.unregister(this);
-        sink.send(this.outMessage);
-        assertTrue(!outMessage.equals(this.inMessage));
-
-        sink.stop();
-        try {
-            sink.send(outMessage);
-        } catch (IllegalStateException e) {
-            badState = true;
-        }
-        assertTrue(badState);
-
-        NoopTopicSink.factory.destroy(topicName);
-        assertTrue(NoopTopicSink.factory.inventory().size() == 0);
-    }
-
-    @Override
-    public void onTopicEvent(CommInfrastructure commType, String topic, String event) {
-        if (commType != CommInfrastructure.NOOP) {
-            return;
-        }
-
-        if (topic == null || !topic.equals(topicName)) {
-            return;
-        }
-
-        this.inMessage = event;
-    }
-}