summaryrefslogtreecommitdiffstats
path: root/engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java
diff options
context:
space:
mode:
authorShiwei Tian <tian.shiwei@zte.com.cn>2017-10-14 10:45:09 +0800
committerShiwei Tian <tian.shiwei@zte.com.cn>2017-10-14 10:56:39 +0800
commite540d3894d2f662a843e5c51535d44b876b9889f (patch)
tree469d7d56958242ad2774437ae3ea9d360a5b6475 /engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java
parent64fcc24209acc0c1d8097e2d10bd9cdef9c2b37c (diff)
modify not publish messages to DMaaP
Issue-ID: HOLMES-71 Change-Id: Iaf87f0250d043aae84e9afc6aaec0f6cdc0a529c Signed-off-by: Shiwei Tian <tian.shiwei@zte.com.cn>
Diffstat (limited to 'engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java')
-rw-r--r--engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java b/engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java
index 8f9a271..45754e2 100644
--- a/engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java
+++ b/engine-d/src/main/java/org/onap/holmes/engine/resources/EngineResources.java
@@ -33,6 +33,7 @@ import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import lombok.extern.slf4j.Slf4j;
import org.jvnet.hk2.annotations.Service;
+import org.onap.holmes.common.dmaap.DmaapService;
import org.onap.holmes.common.exception.CorrelationException;
import org.onap.holmes.common.utils.ExceptionUtil;
import org.onap.holmes.common.utils.LanguageUtil;
@@ -65,8 +66,9 @@ public class EngineResources {
CorrelationRuleResponse crResponse = new CorrelationRuleResponse();
Locale locale = LanguageUtil.getLocale(httpRequest);
try {
-
String packageName = droolsEngine.deployRule(deployRuleRequest, locale);
+ DmaapService.loopControlNames
+ .put(packageName, deployRuleRequest.getLoopControlName());
log.info("Rule deployed. Package name: " + packageName);
crResponse.setPackageName(packageName);