+
+ private void deleteRequestIdIfNecessary(PolicyMsg policyMsg){
+ EVENT_STATUS status = policyMsg.getClosedLoopEventStatus();
+ if(EVENT_STATUS.ABATED.equals(status)) {
+ String requestId = policyMsg.getRequestID();
+ for(Entry<String, String> kv: uniqueRequestIdCache.entrySet()) {
+ if(kv.getValue().equals(requestId)) {
+ uniqueRequestIdCache.remove(kv.getKey());
+ break;
+ }
+ }
+ log.info("An alarm is cleared and the corresponding requestId is deleted successfully");
+ }
+ }