Sonar major issues

 Replace with the diamond operator
Sonar Link:
https://sonar.onap.org/project/issues?assignees=sumapriya&id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr&open=AWU41WkgwGn37JfbyHyq&resolved=false&severities=MAJOR
Location:
src/main/java/com/att/dmf/mr/backends/kafka/KafkaConsumerCache.java
Line No:L166 L395 L419 L463

Change-Id: Ie766fa53303bf45a4e028c5a557ce45f8e211f99
Issue-ID: DMAAP-616
Signed-off-by: Sumapriya Sarvepalli <ss00493505@techmahindra.com>

diff --git a/src/main/java/com/att/dmf/mr/backends/kafka/KafkaConsumerCache.java b/src/main/java/com/att/dmf/mr/backends/kafka/KafkaConsumerCache.java
index 4340cae..126711a 100644 (file)
--- a/src/main/java/com/att/dmf/mr/backends/kafka/KafkaConsumerCache.java
+++ b/src/main/java/com/att/dmf/mr/backends/kafka/KafkaConsumerCache.java
@@ -163,7 +163,7 @@ public class KafkaConsumerCache {
                        strkSetting_ZkBasePath = kDefault_ZkBasePath;
                fBaseZkPath = strkSetting_ZkBasePath;
 
-               fConsumers = new ConcurrentHashMap<String, Kafka011Consumer>();
+               fConsumers = new ConcurrentHashMap<>();
                fSweepScheduler = Executors.newScheduledThreadPool(1);
 
                curatorConsumerCache = null;
@@ -392,7 +392,7 @@ public class KafkaConsumerCache {
                        throws KafkaConsumerCacheException {
                if (getStatus() != KafkaConsumerCache.Status.CONNECTED)
                        throw new KafkaConsumerCacheException("The cache service is unavailable.");
-               ArrayList<Kafka011Consumer> kcl = new ArrayList<Kafka011Consumer>();
+               ArrayList<Kafka011Consumer> kcl = new ArrayList<>();
                // final String consumerKey = makeConsumerKey(topic, consumerGroupId,
                // clientId);
                Enumeration<String> strEnum = fConsumers.keys();
@@ -416,7 +416,7 @@ public class KafkaConsumerCache {
        public ArrayList<Kafka011Consumer> getConsumerListForCG(String group) throws KafkaConsumerCacheException {
                if (getStatus() != KafkaConsumerCache.Status.CONNECTED)
                        throw new KafkaConsumerCacheException("The cache service is unavailable.");
-               ArrayList<Kafka011Consumer> kcl = new ArrayList<Kafka011Consumer>();
+               ArrayList<Kafka011Consumer> kcl = new ArrayList<>();
                // final String consumerKey = makeConsumerKey(topic, consumerGroupId,
                // clientId);
                Enumeration<String> strEnum = fConsumers.keys();
@@ -460,7 +460,7 @@ public class KafkaConsumerCache {
        }
 
        public Collection<? extends Consumer> getConsumers() {
-               return new LinkedList<Kafka011Consumer>(fConsumers.values());
+               return new LinkedList<>(fConsumers.values());
        }
 
        /**