*/
package org.onap.holmes.common.dmaap;
+import java.util.Map.Entry;
import java.util.Optional;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
publisher.setUrl(DcaeConfigurationsCache.getPubSecInfo(dmaapConfigKey).getDmaapInfo()
.getTopicUrl());
publisher.publish(policyMsg);
+ deleteRequestId(policyMsg);
log.info("send policyMsg: " + GsonUtil.beanToJson(policyMsg));
} catch (CorrelationException e) {
log.error("Failed to publish the control loop event to DMaaP", e);
}
return vmEntity;
}
+
+ private void deleteRequestId(PolicyMsg policyMsg){
+ EVENT_STATUS status = policyMsg.getClosedLoopEventStatus();
+ if(EVENT_STATUS.ABATED.equals(status)) {
+ String requestId = policyMsg.getRequestID();
+ for(Entry<String, String> kv: alarmUniqueRequestID.entrySet()) {
+ if(kv.getValue().equals(requestId)) {
+ alarmUniqueRequestID.remove(kv.getKey());
+ break;
+ }
+ }
+ log.info("Clear alarm, requestId deleted successful");
+ }
+ }
}