aboutsummaryrefslogtreecommitdiffstats
path: root/fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java
diff options
context:
space:
mode:
Diffstat (limited to 'fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java')
-rw-r--r--fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java79
1 files changed, 0 insertions, 79 deletions
diff --git a/fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java b/fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java
deleted file mode 100644
index 7a25e77b..00000000
--- a/fabric-discovery-plugin/provider/src/test/java/jtest/org/onap/ccsdk/sli/plugins/fabricdiscovery/TestFabricDiscoveryPlugin.java
+++ /dev/null
@@ -1,79 +0,0 @@
-package jtest.org.onap.ccsdk.sli.plugins.fabricdiscovery;
-
-import java.util.HashMap;
-import java.util.Map;
-import org.junit.Assert;
-import org.junit.Test;
-import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
-import org.onap.ccsdk.sli.plugins.fabricdiscovery.FabricDiscoveryPlugin;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Created by arun on 9/18/17.
- */
-
-public class TestFabricDiscoveryPlugin {
- private static final Logger LOG = LoggerFactory.getLogger(TestFabricDiscoveryPlugin.class);
- private static final String C_STREAM =
- "ws://localhost:8185/data-change-event-subscription/network-topology:network-topology/datastore=CONFIGURATION/scope=BASE";
- private static final String W_STREAM =
- "get://localhost:8185/data-change-event-subscription/network-topology:network/datastore=CONFIGURATION/scope=BASE";
- private final String FB_DISCOVERY_STATUS = "fb-response";
-
- @Test
- public void connectToNotificationServerSuccess() throws Exception {
- SvcLogicContext ctx = new SvcLogicContext();
- String stream = C_STREAM;
-
- Map<String, String> p = new HashMap<String, String>();
- p.put("stream", stream);
- p.put("enable", "true");
-
- FabricDiscoveryPlugin fdp = new FabricDiscoveryPlugin();
- fdp.processDcNotificationStream(p, ctx);
- Assert.assertEquals("Success", ctx.getAttribute(FB_DISCOVERY_STATUS));
- }
-
- @Test
- public void connectToNotificationServerFailure() throws Exception {
- SvcLogicContext ctx = new SvcLogicContext();
- String stream = W_STREAM;
-
- Map<String, String> p = new HashMap<>();
- p.put("stream", stream);
- p.put("enable", "true");
-
- FabricDiscoveryPlugin fdp = new FabricDiscoveryPlugin();
- try {
- fdp.processDcNotificationStream(p, ctx);
- LOG.info("Connection to Stream:{} succeeded.", stream);
- } catch (Exception e) {
- LOG.info("Received Exception while connecting to Fabric Discovery notification server: {}", e.getMessage());
- } finally {
- Assert.assertEquals("Failure", ctx.getAttribute(FB_DISCOVERY_STATUS));
- }
- }
-
- @Test
- public void validateParameterEnableFailure() throws Exception {
- SvcLogicContext ctx = new SvcLogicContext();
- String stream = C_STREAM;
- final String W_ENABLE_STR = "bad enable parameter";
-
- Map<String, String> p = new HashMap<>();
- p.put("stream", stream);
- p.put("enable", W_ENABLE_STR);
-
- FabricDiscoveryPlugin fdp = new FabricDiscoveryPlugin();
- try {
- fdp.processDcNotificationStream(p, ctx);
- LOG.info("Connection to Stream:{} succeeded.", stream);
- } catch (Exception e) {
- LOG.info("Received Exception while connecting to Fabric Discovery notification server: {}", e.getMessage());
- } finally {
- Assert.assertEquals("Failure", ctx.getAttribute(FB_DISCOVERY_STATUS));
- }
- }
-
-}