X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2Fclient%2Fimpl%2FMRConsumerImpl.java;h=d224bdf413dbf71d481d29bab0b84452f7a25a8f;hb=64986f72ea27cc757612ccba38c628b6089119fa;hp=a1a52aa6813041e570893ebfa6c97e00cfb14351;hpb=64465dad905ee3f636f5b5df8349eec8c263f1f1;p=dmaap%2Fmessagerouter%2Fdmaapclient.git 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)) {