modify dace polling and loopControlName

Issue-ID: HOLMES-67

Change-Id: If538c63d4ab173bd4ea0aa0bb3af8afcce24a177
Signed-off-by: Shiwei Tian <tian.shiwei@zte.com.cn>

1 files changed, 4 insertions, 1 deletions

diff --git a/rulemgt/src/main/java/org/onap/holmes/rulemgt/wrapper/RuleMgtWrapper.java b/rulemgt/src/main/java/org/onap/holmes/rulemgt/wrapper/RuleMgtWrapper.java
index beffa56..856171b 100644
--- a/rulemgt/src/main/java/org/onap/holmes/rulemgt/wrapper/RuleMgtWrapper.java
+++ b/rulemgt/src/main/java/org/onap/holmes/rulemgt/wrapper/RuleMgtWrapper.java
@@ -23,6 +23,7 @@ import javax.inject.Inject;
 import javax.inject.Singleton;

 import lombok.extern.slf4j.Slf4j;

 import org.jvnet.hk2.annotations.Service;

+import org.onap.holmes.common.dmaap.DmaapService;

 import org.onap.holmes.rulemgt.bean.request.CorrelationCheckRule4Engine;

 import org.onap.holmes.rulemgt.bean.response.RuleResult4API;

 import org.onap.holmes.rulemgt.constant.RuleMgtConstant;

@@ -72,7 +73,9 @@ public class RuleMgtWrapper {
         if (ruleTemp != null) {

             throw new CorrelationException("A rule with the same name already exists.");

         }

-        correlationRule.setPackageName(deployRule2Engine(correlationRule));

+        String packageName = deployRule2Engine(correlationRule);

+        DmaapService.loopControlNames.put(packageName, ruleCreateRequest.getLoopControlName());

+        correlationRule.setPackageName(packageName);

         CorrelationRule result = correlationRuleDao.saveRule(correlationRule);

         RuleAddAndUpdateResponse ruleAddAndUpdateResponse = new RuleAddAndUpdateResponse();

         ruleAddAndUpdateResponse.setRuleId(result.getRid());