diff options
Diffstat (limited to 'UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/service/DMaapService.java')
-rw-r--r-- | UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/service/DMaapService.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/service/DMaapService.java b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/service/DMaapService.java index d07dd04..49d68be 100644 --- a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/service/DMaapService.java +++ b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/service/DMaapService.java @@ -66,16 +66,16 @@ public class DMaapService { } - if (list.size() == 0) { + if (list.isEmpty()) { Thread.sleep(pollingInternalInt); } LOGGER.debug("number of messages to be converted :{}", list.size()); - if (list.size() != 0) { + if (!list.isEmpty()) { String val = ((LinkedList<String>) list).removeFirst(); List<String> messages = new ArrayList<>(); String vesEvent = processReceivedJson(val); - if (!(vesEvent.isEmpty() || vesEvent.equals(null) || vesEvent.equals(""))) { + if (vesEvent!=null && (!(vesEvent.isEmpty() || vesEvent.equals("")))) { messages.add(vesEvent); publisher.publish(messages); LOGGER.info("Message successfully published to DMaaP Topic"); |