summaryrefslogtreecommitdiffstats
path: root/controlloop/common/eventmanager
diff options
context:
space:
mode:
Diffstat (limited to 'controlloop/common/eventmanager')
-rw-r--r--controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java2
-rw-r--r--controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/EventManagerServices.java28
-rw-r--r--controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/EventManagerServicesTest.java17
3 files changed, 14 insertions, 33 deletions
diff --git a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java
index 69cbe7839..05563ca8d 100644
--- a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java
+++ b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java
@@ -75,7 +75,7 @@ public class ControlLoopEventManager2 implements ManagerContext, Serializable {
private static final Logger logger = LoggerFactory.getLogger(ControlLoopEventManager2.class);
private static final long serialVersionUID = -1216568161322872641L;
- private static final String EVENT_MANAGER_SERVICE_CONFIG = "config/event-manager.properties";
+ private static final String EVENT_MANAGER_SERVICE_CONFIG = "event-manager";
public static final String PROV_STATUS_ACTIVE = "ACTIVE";
private static final String VM_NAME = "VM_NAME";
private static final String VNF_NAME = "VNF_NAME";
diff --git a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/EventManagerServices.java b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/EventManagerServices.java
index 3fbedcb1f..8ce3cb188 100644
--- a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/EventManagerServices.java
+++ b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/EventManagerServices.java
@@ -20,15 +20,11 @@
package org.onap.policy.controlloop.eventmanager;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.InputStream;
import java.util.Map;
import java.util.Properties;
import lombok.Getter;
import org.onap.policy.common.parameters.ValidationResult;
import org.onap.policy.common.utils.properties.PropertyObjectUtils;
-import org.onap.policy.common.utils.resources.ResourceUtils;
import org.onap.policy.controlloop.actor.guard.GuardActorServiceProvider;
import org.onap.policy.controlloop.actor.guard.GuardConfig;
import org.onap.policy.controlloop.actor.guard.GuardOperation;
@@ -39,6 +35,7 @@ import org.onap.policy.controlloop.ophistory.OperationHistoryDataManager;
import org.onap.policy.controlloop.ophistory.OperationHistoryDataManagerImpl;
import org.onap.policy.controlloop.ophistory.OperationHistoryDataManagerParams;
import org.onap.policy.controlloop.ophistory.OperationHistoryDataManagerStub;
+import org.onap.policy.drools.persistence.SystemPersistenceConstants;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -82,9 +79,8 @@ public class EventManagerServices {
* @return the properties that were loaded from the configuration file
*/
public Properties startActorService(String configFileName) {
- try (InputStream inpstr = openConfigFile(configFileName)) {
- Properties props = new Properties();
- props.load(inpstr);
+ try {
+ Properties props = SystemPersistenceConstants.getManager().getProperties(configFileName);
Map<String, Object> parameters = PropertyObjectUtils.toObject(props, ACTOR_SERVICE_PROPERTIES);
PropertyObjectUtils.compressLists(parameters);
@@ -94,29 +90,13 @@ public class EventManagerServices {
return props;
- } catch (RuntimeException | IOException e) {
+ } catch (RuntimeException e) {
logger.error("cannot configure/start actor service");
throw new IllegalStateException(e);
}
}
/**
- * Opens the config file.
- *
- * @param configFileName configuration file name
- * @return the file's input stream
- * @throws FileNotFoundException if the file cannot be found
- */
- private InputStream openConfigFile(String configFileName) throws FileNotFoundException {
- InputStream inpstr = ResourceUtils.getResourceAsStream(configFileName);
- if (inpstr == null) {
- throw new FileNotFoundException(configFileName);
- }
-
- return inpstr;
- }
-
- /**
* Determines if guards are enabled.
*
* @return {@code true} if guards are enabled, {@code false} otherwise
diff --git a/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/EventManagerServicesTest.java b/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/EventManagerServicesTest.java
index b32fb4438..ea3fff311 100644
--- a/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/EventManagerServicesTest.java
+++ b/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/EventManagerServicesTest.java
@@ -37,7 +37,7 @@ import org.onap.policy.common.endpoints.http.client.HttpClientFactoryInstance;
import org.onap.policy.controlloop.actorserviceprovider.ActorService;
import org.onap.policy.controlloop.ophistory.OperationHistoryDataManagerImpl;
import org.onap.policy.controlloop.ophistory.OperationHistoryDataManagerStub;
-import org.onap.policy.drools.utils.PropertyUtil;
+import org.onap.policy.drools.persistence.SystemPersistenceConstants;
public class EventManagerServicesTest {
private static final String FILEPFX = "eventService/";
@@ -54,8 +54,9 @@ public class EventManagerServicesTest {
// start with a clean slate
HttpClientFactoryInstance.getClientFactory().destroy();
- Properties props =
- PropertyUtil.getProperties("src/test/resources/eventService/event-svc-http-client.properties");
+ SystemPersistenceConstants.getManager().setConfigurationDir("src/test/resources");
+
+ Properties props = SystemPersistenceConstants.getManager().getProperties("eventService/event-svc-http-client");
HttpClientFactoryInstance.getClientFactory().build(props);
}
@@ -72,12 +73,12 @@ public class EventManagerServicesTest {
@Test
public void testEventManagerServices_testGetActorService() {
// try with guard disabled - should use DB stub
- services = new EventManagerServices(FILEPFX + "event-svc-guard-disabled.properties");
+ services = new EventManagerServices(FILEPFX + "event-svc-guard-disabled");
assertTrue(services.getDataManager() instanceof OperationHistoryDataManagerStub);
assertNotNull(services.getActorService());
// try with guard enabled - should create a DB connection
- services = new EventManagerServices(FILEPFX + "event-svc-with-db.properties");
+ services = new EventManagerServices(FILEPFX + "event-svc-with-db");
assertTrue(services.getDataManager() instanceof OperationHistoryDataManagerImpl);
assertNotNull(services.getActorService());
}
@@ -91,11 +92,11 @@ public class EventManagerServicesTest {
@Test
public void testIsGuardEnabled() {
// cannot check guard
- services = new EventManagerServices(FILEPFX + "event-svc-no-guard-actor.properties");
+ services = new EventManagerServices(FILEPFX + "event-svc-no-guard-actor");
assertTrue(services.getDataManager() instanceof OperationHistoryDataManagerStub);
// force exception when checking for guard operator
- services = new EventManagerServices(FILEPFX + "event-svc-with-db.properties") {
+ services = new EventManagerServices(FILEPFX + "event-svc-with-db") {
@Override
public ActorService getActorService() {
ActorService svc = mock(ActorService.class);
@@ -108,7 +109,7 @@ public class EventManagerServicesTest {
@Test
public void testMakeDataManager() {
- assertThatThrownBy(() -> new EventManagerServices(FILEPFX + "event-svc-invalid-db.properties"));
+ assertThatThrownBy(() -> new EventManagerServices(FILEPFX + "event-svc-invalid-db"));
}