X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=holmes-actions%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Fcommon%2Fdmaap%2FDmaapService.java;h=e3f6e584c0b58e288a3314aa44054c77033ad4a1;hb=4f48419205730ecc3e34d93efc99cd76b81f9a59;hp=f19b89ce6bdd43475dc2cc7acc0851daadbd2ea3;hpb=b6920b68810a4679257ed72437dd7152a0b291d0;p=holmes%2Fcommon.git diff --git a/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/DmaapService.java b/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/DmaapService.java index f19b89c..e3f6e58 100644 --- a/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/DmaapService.java +++ b/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/DmaapService.java @@ -15,6 +15,7 @@ */ package org.onap.holmes.common.dmaap; +import java.util.Map.Entry; import java.util.Optional; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; @@ -70,14 +71,14 @@ public class DmaapService { enrichVnfInfo(vmEntity, childAlarm, policyMsg); policyMsg.setClosedLoopEventStatus(EVENT_STATUS.ONSET); try { - policyMsg.getAai().put("vserver.in-maint", Boolean.valueOf(vmEntity.getInMaint()).booleanValue()); + policyMsg.getAai().put("vserver.in-maint", vmEntity.getInMaint()); } catch (Exception e) { log.error("Failed to parse the field \"in-maint\". A boolean string (\"true\"/\"false\")" + " is expected but the actual value is " + vmEntity.getInMaint() + ".", e); } try { policyMsg.getAai().put("vserver.is-closed-loop-disabled", - Boolean.valueOf(vmEntity.getClosedLoopDisable()).booleanValue()); + vmEntity.getClosedLoopDisable()); } catch (Exception e) { log.error("Failed to parse the field \"is-closed-loop-disabled\". A boolean string (\"true\"/\"false\")" + " is expected but the actual value is " + vmEntity.getClosedLoopDisable() + ".", e); @@ -186,12 +187,13 @@ public class DmaapService { } private void deleteRequestId(PolicyMsg policyMsg){ - String status = policyMsg.getClosedLoopEventStatus().toString(); - if(status == "ABATED"){ + EVENT_STATUS status = policyMsg.getClosedLoopEventStatus(); + if(EVENT_STATUS.ABATED.equals(status)) { String requestId = policyMsg.getRequestID(); - for(String key: alarmUniqueRequestID.keySet()){ - if(alarmUniqueRequestID.get(key).equals(requestId)){ - alarmUniqueRequestID.remove(key); + for(Entry kv: alarmUniqueRequestID.entrySet()) { + if(kv.getValue().equals(requestId)) { + alarmUniqueRequestID.remove(kv.getKey()); + break; } } log.info("Clear alarm, requestId deleted successful");