From: sunil unnava Date: Mon, 11 Feb 2019 14:12:16 +0000 (+0000) Subject: Merge "Sonar majior issues" X-Git-Tag: 1.1.10~15 X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=ebcde5d635d5ceab258ce3aa2fbabef658a3ad0e;hp=211967cf8abd6eb0c39c19b52dc334f0a2359558;p=dmaap%2Fmessagerouter%2Fdmaapclient.git Merge "Sonar majior issues" --- diff --git a/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java b/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java index 60e0666..abf3736 100644 --- a/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java +++ b/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java @@ -149,7 +149,7 @@ public class MRClientBuilders */ public MRConsumer build () { - if ( fHosts == null || fHosts.size() == 0 || fTopic == null ) + if ( fHosts == null || fHosts.isEmpty() || fTopic == null ) { throw new IllegalArgumentException ( "You must provide at least one host and a topic name." ); } @@ -208,7 +208,7 @@ public class MRClientBuilders */ public PublisherBuilder usingHosts ( String[] hostSet ) { - final TreeSet hosts = new TreeSet (); + final TreeSet hosts = new TreeSet<> (); for ( String hp : hostSet ) { hosts.add ( hp ); diff --git a/src/main/java/org/onap/dmaap/mr/client/impl/MRBaseClient.java b/src/main/java/org/onap/dmaap/mr/client/impl/MRBaseClient.java index ecea21c..8ed7dd8 100644 --- a/src/main/java/org/onap/dmaap/mr/client/impl/MRBaseClient.java +++ b/src/main/java/org/onap/dmaap/mr/client/impl/MRBaseClient.java @@ -75,7 +75,7 @@ public class MRBaseClient extends HttpClient implements MRClient { if (a == null) return null; - final TreeSet set = new TreeSet(); + final TreeSet set = new TreeSet<>(); for (int i = 0; i < a.length(); i++) { set.add(a.getString(i)); } diff --git a/src/main/java/org/onap/dmaap/mr/client/impl/MRConstants.java b/src/main/java/org/onap/dmaap/mr/client/impl/MRConstants.java index f6d9578..5ed44c6 100644 --- a/src/main/java/org/onap/dmaap/mr/client/impl/MRConstants.java +++ b/src/main/java/org/onap/dmaap/mr/client/impl/MRConstants.java @@ -110,7 +110,7 @@ class MRConstants */ public static List createHostsList(Collection hosts) { - final ArrayList convertedHosts = new ArrayList (); + final ArrayList convertedHosts = new ArrayList<> (); for ( String host : hosts ) { if ( host.length () == 0 ) continue; diff --git a/src/main/java/org/onap/dmaap/mr/client/impl/MRConsumerImpl.java b/src/main/java/org/onap/dmaap/mr/client/impl/MRConsumerImpl.java index a1a52aa..d224bdf 100644 --- a/src/main/java/org/onap/dmaap/mr/client/impl/MRConsumerImpl.java +++ b/src/main/java/org/onap/dmaap/mr/client/impl/MRConsumerImpl.java @@ -241,7 +241,7 @@ public class MRConsumerImpl extends MRBaseClient implements MRConsumer { @Override public MRConsumerResponse fetchWithReturnConsumerResponse(int timeoutMs, int limit) { - final LinkedList msgs = new LinkedList(); + final LinkedList msgs = new LinkedList<>(); MRConsumerResponse mrConsumerResponse = new MRConsumerResponse(); try { if (ProtocolTypeConstants.DME2.getValue().equalsIgnoreCase(protocolFlag)) { diff --git a/src/main/java/org/onap/dmaap/mr/client/impl/MRMetaClient.java b/src/main/java/org/onap/dmaap/mr/client/impl/MRMetaClient.java index 9051b99..04b26d5 100644 --- a/src/main/java/org/onap/dmaap/mr/client/impl/MRMetaClient.java +++ b/src/main/java/org/onap/dmaap/mr/client/impl/MRMetaClient.java @@ -51,7 +51,7 @@ public class MRMetaClient extends MRBaseClient implements MRTopicManager, MRIden @Override public Set getTopics () throws IOException { - final TreeSet set = new TreeSet (); + final TreeSet set = new TreeSet<> (); try { final JSONObject topicSet = get ( "/topics" ); diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumer.java b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumer.java index a7f283c..a5c0c3a 100644 --- a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumer.java +++ b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumer.java @@ -62,7 +62,7 @@ public class SimpleExampleConsumer { Thread.sleep(2); i++; for (String msg : cc.fetch()) { - // System.out.println ( "" + (++count) + ": " + msg ); + System.out.println(msg); }