diff options
Diffstat (limited to 'rulemgt/src/main/java/org/onap/holmes/rulemgt/dcae/ConfigFileScanningTask.java')
-rw-r--r-- | rulemgt/src/main/java/org/onap/holmes/rulemgt/dcae/ConfigFileScanningTask.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/rulemgt/src/main/java/org/onap/holmes/rulemgt/dcae/ConfigFileScanningTask.java b/rulemgt/src/main/java/org/onap/holmes/rulemgt/dcae/ConfigFileScanningTask.java index fc042ad..ee8d4f9 100644 --- a/rulemgt/src/main/java/org/onap/holmes/rulemgt/dcae/ConfigFileScanningTask.java +++ b/rulemgt/src/main/java/org/onap/holmes/rulemgt/dcae/ConfigFileScanningTask.java @@ -36,11 +36,13 @@ import jakarta.ws.rs.core.MediaType; import java.io.File; import java.nio.file.Paths; import java.util.*; +import java.util.stream.Collectors; public class ConfigFileScanningTask implements Runnable { final public static long POLLING_PERIOD = 30L; final private static Logger LOGGER = LoggerFactory.getLogger(ConfigFileScanningTask.class); final private static long FILE_SIZE_LMT = 1024 * 1024 * 10; // 10MB + final private static String CREATOR = "__SYSTEM__DEFAULT__"; private String configFile = "/opt/hrmrules/index.json"; private ConfigFileScanner configFileScanner; private String url; @@ -175,7 +177,8 @@ public class ConfigFileScanningTask implements Runnable { RuleQueryListResponse ruleQueryListResponse = JerseyClient.newInstance().get(url, RuleQueryListResponse.class); List<RuleResult4API> deployedRules = Collections.EMPTY_LIST; if (null != ruleQueryListResponse) { - deployedRules = ruleQueryListResponse.getCorrelationRules(); + deployedRules = ruleQueryListResponse.getCorrelationRules() + .stream().filter(r -> CREATOR.equals(r.getCreator())).collect(Collectors.toList()); } return deployedRules; } @@ -197,6 +200,7 @@ public class ConfigFileScanningTask implements Runnable { ruleCreateRequest.setContent(contents); ruleCreateRequest.setDescription(""); ruleCreateRequest.setEnabled(1); + ruleCreateRequest.setCreator(CREATOR); return ruleCreateRequest; } |