summaryrefslogtreecommitdiffstats
path: root/fabric-discovery-plugin/provider/src
diff options
context:
space:
mode:
authorsurya-huawei <a.u.surya@huawei.com>2017-09-21 16:47:19 +0530
committersurya-huawei <a.u.surya@huawei.com>2017-09-21 16:51:17 +0530
commit23fc985b7163470ed5f2a1d7cbf2e3f0431a8c8a (patch)
tree8bb9795b6adee8549dd8511c9ba9441c6d544014 /fabric-discovery-plugin/provider/src
parente599a8ec658120298ed16a1e9e47e23c485cde6b (diff)
Replace type specification with diamond operator
Major issue in sli/plugins module *Used diamond operator to reduce verbosity of generics code *Removed unnecessary parantheses as they can be misleading sometimes Issue-Id: CCSDK-87 Change-Id: I81c0b566f5beb81d3733549a2f9de81b50d6814c Signed-off-by: surya-huawei <a.u.surya@huawei.com>
Diffstat (limited to 'fabric-discovery-plugin/provider/src')
-rw-r--r--fabric-discovery-plugin/provider/src/main/java/org/onap/ccsdk/sli/plugins/fabricdiscovery/FabricDiscoveryPlugin.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/fabric-discovery-plugin/provider/src/main/java/org/onap/ccsdk/sli/plugins/fabricdiscovery/FabricDiscoveryPlugin.java b/fabric-discovery-plugin/provider/src/main/java/org/onap/ccsdk/sli/plugins/fabricdiscovery/FabricDiscoveryPlugin.java
index 66452758d..99e171f6e 100644
--- a/fabric-discovery-plugin/provider/src/main/java/org/onap/ccsdk/sli/plugins/fabricdiscovery/FabricDiscoveryPlugin.java
+++ b/fabric-discovery-plugin/provider/src/main/java/org/onap/ccsdk/sli/plugins/fabricdiscovery/FabricDiscoveryPlugin.java
@@ -44,7 +44,7 @@ public class FabricDiscoveryPlugin implements SvcLogicJavaPlugin, IFabricDiscove
public FabricDiscoveryPlugin() {
service = Executors.newFixedThreadPool(10);
- streamMap = new ConcurrentHashMap<String, WebSocketClient> ();
+ streamMap = new ConcurrentHashMap<>();
}
@Override
@@ -70,7 +70,7 @@ public class FabricDiscoveryPlugin implements SvcLogicJavaPlugin, IFabricDiscove
}
ctx.setAttribute(pfx + FB_DISCOVERY_STATUS, "Success");
- LOG.info("{} monitoring notification stream: {}", (enable) ? "START" : "STOP", stream);
+ LOG.info("{} monitoring notification stream: {}", enable ? "START" : "STOP", stream);
try {
service.execute(new Runnable () {