+
+ @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));
+ }
+ }
+