diff options
6 files changed, 7 insertions, 7 deletions
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<String> hosts = new TreeSet<String> (); + final TreeSet<String> 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<String> set = new TreeSet<String>(); + final TreeSet<String> 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<HttpHost> createHostsList(Collection<String> hosts) { - final ArrayList<HttpHost> convertedHosts = new ArrayList<HttpHost> (); + final ArrayList<HttpHost> 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<String> msgs = new LinkedList<String>(); + final LinkedList<String> 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<String> getTopics () throws IOException { - final TreeSet<String> set = new TreeSet<String> (); + final TreeSet<String> 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); } |