aboutsummaryrefslogtreecommitdiffstats
path: root/main/src
diff options
context:
space:
mode:
Diffstat (limited to 'main/src')
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/comm/PdpModifyRequestMap.java112
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/comm/Publisher.java6
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/comm/msgdata/RequestImpl.java6
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/comm/msgdata/UpdateReq.java2
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/PapRestControllerV1.java2
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/PapRestServer.java14
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupQueryControllerV1.java6
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupStateChangeControllerV1.java6
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java7
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java4
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/depundep/ProviderBase.java8
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/startstop/Main.java10
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java16
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/startstop/PapCommandLineArguments.java2
-rw-r--r--main/src/test/java/org/onap/policy/pap/main/parameters/CommonTestData.java2
-rw-r--r--main/src/test/resources/simpleDeploy/createGroupNewPolicy.json2
-rw-r--r--main/src/test/resources/simpleDeploy/daoPolicyList.json2
-rw-r--r--main/src/test/resources/simpleDeploy/policy.json2
-rw-r--r--main/src/test/resources/simpleDeploy/upgradeGroupDao.json2
-rw-r--r--main/src/test/resources/simpleDeploy/upgradeGroupPolicy2.json2
-rw-r--r--main/src/test/resources/simpleDeploy/upgradeGroupPolicy3.json2
-rw-r--r--main/src/test/resources/simpleDeploy/upgradeGroupPolicy4.json2
22 files changed, 110 insertions, 107 deletions
diff --git a/main/src/main/java/org/onap/policy/pap/main/comm/PdpModifyRequestMap.java b/main/src/main/java/org/onap/policy/pap/main/comm/PdpModifyRequestMap.java
index c65ebb3a..8dcb9794 100644
--- a/main/src/main/java/org/onap/policy/pap/main/comm/PdpModifyRequestMap.java
+++ b/main/src/main/java/org/onap/policy/pap/main/comm/PdpModifyRequestMap.java
@@ -206,62 +206,6 @@ public class PdpModifyRequestMap {
}
/**
- * Starts the next request associated with a PDP.
- *
- * @param requests current set of requests
- * @param request the request that just completed
- */
- private void startNextRequest(PdpRequests requests, Request request) {
- if (!requests.startNextRequest(request)) {
- pdp2requests.remove(requests.getPdpName(), requests);
- }
- }
-
- /**
- * Disables a PDP by removing it from its subgroup and then sending it a PASSIVE
- * request.
- *
- * @param requests the requests associated with the PDP to be disabled
- */
- private void disablePdp(PdpRequests requests) {
-
- // remove the requests from the map
- if (!pdp2requests.remove(requests.getPdpName(), requests)) {
- // don't have the info we need to disable it
- logger.warn("no requests with which to disable {}", requests.getPdpName());
- return;
- }
-
- logger.warn("disabling {}", requests.getPdpName());
-
- requests.stopPublishing();
-
- // remove the PDP from all groups
- boolean removed = false;
- try {
- removed = removeFromGroups(requests.getPdpName());
- } catch (PfModelException e) {
- logger.info("unable to remove PDP {} from subgroup", requests.getPdpName(), e);
- }
-
- // send the state change
- PdpStateChange change = new PdpStateChange();
- change.setName(requests.getPdpName());
- change.setState(PdpState.PASSIVE);
-
- if (removed) {
- // send an update, too
- PdpUpdate update = new PdpUpdate();
- update.setName(requests.getPdpName());
-
- addRequest(update, change);
-
- } else {
- addRequest(change);
- }
- }
-
- /**
* Removes a PDP from all active groups.
*
* @param pdpName name of the PDP to be removed
@@ -384,5 +328,61 @@ public class PdpModifyRequestMap {
public void retryCountExhausted() {
disablePdp(requests);
}
+
+ /**
+ * Starts the next request associated with a PDP.
+ *
+ * @param requests current set of requests
+ * @param request the request that just completed
+ */
+ private void startNextRequest(PdpRequests requests, Request request) {
+ if (!requests.startNextRequest(request)) {
+ pdp2requests.remove(requests.getPdpName(), requests);
+ }
+ }
+
+ /**
+ * Disables a PDP by removing it from its subgroup and then sending it a PASSIVE
+ * request.
+ *
+ * @param requests the requests associated with the PDP to be disabled
+ */
+ private void disablePdp(PdpRequests requests) {
+
+ // remove the requests from the map
+ if (!pdp2requests.remove(requests.getPdpName(), requests)) {
+ // don't have the info we need to disable it
+ logger.warn("no requests with which to disable {}", requests.getPdpName());
+ return;
+ }
+
+ logger.warn("disabling {}", requests.getPdpName());
+
+ requests.stopPublishing();
+
+ // remove the PDP from all groups
+ boolean removed = false;
+ try {
+ removed = removeFromGroups(requests.getPdpName());
+ } catch (PfModelException e) {
+ logger.info("unable to remove PDP {} from subgroup", requests.getPdpName(), e);
+ }
+
+ // send the state change
+ PdpStateChange change = new PdpStateChange();
+ change.setName(requests.getPdpName());
+ change.setState(PdpState.PASSIVE);
+
+ if (removed) {
+ // send an update, too
+ PdpUpdate update = new PdpUpdate();
+ update.setName(requests.getPdpName());
+
+ addRequest(update, change);
+
+ } else {
+ addRequest(change);
+ }
+ }
}
}
diff --git a/main/src/main/java/org/onap/policy/pap/main/comm/Publisher.java b/main/src/main/java/org/onap/policy/pap/main/comm/Publisher.java
index 6032d17e..ec54dd5a 100644
--- a/main/src/main/java/org/onap/policy/pap/main/comm/Publisher.java
+++ b/main/src/main/java/org/onap/policy/pap/main/comm/Publisher.java
@@ -107,11 +107,9 @@ public class Publisher implements Runnable {
}
PdpMessage data = token.replaceItem(null);
- if (data == null) {
- continue;
+ if (data != null) {
+ client.send(data);
}
-
- client.send(data);
}
}
diff --git a/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/RequestImpl.java b/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/RequestImpl.java
index 45ca2db4..b9a0a6dc 100644
--- a/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/RequestImpl.java
+++ b/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/RequestImpl.java
@@ -112,7 +112,7 @@ public abstract class RequestImpl implements Request {
() -> timer = params.getTimers().register(this.message.getRequestId(), this::handleTimeout),
() -> timer.cancel())
.addAction("enqueue",
- () -> enqueue(),
+ this::enqueue,
() -> {
// do not remove from the queue - token may be re-used
});
@@ -260,7 +260,7 @@ public abstract class RequestImpl implements Request {
String reason = checkResponse(response);
if (reason != null) {
- logger.info("{} PDP data mismatch: {}", getName(), reason);
+ logger.info("{} PDP data mismatch via {}: {}", getName(), infra, reason);
listener.failure(pdpName, reason);
return;
}
@@ -286,7 +286,7 @@ public abstract class RequestImpl implements Request {
stopPublishing();
if (!bumpRetryCount()) {
- logger.info("{} timeout - retry count {} exhausted", getName(), retryCount);
+ logger.info("{} timeout {} - retry count {} exhausted", getName(), timerName, retryCount);
listener.retryCountExhausted();
return;
}
diff --git a/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/UpdateReq.java b/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/UpdateReq.java
index 0f6d73fc..9067131f 100644
--- a/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/UpdateReq.java
+++ b/main/src/main/java/org/onap/policy/pap/main/comm/msgdata/UpdateReq.java
@@ -62,7 +62,7 @@ public class UpdateReq extends RequestImpl {
return reason;
}
- PdpUpdate message = (PdpUpdate) getMessage();
+ PdpUpdate message = getMessage();
if (!StringUtils.equals(message.getPdpGroup(), response.getPdpGroup())) {
return "group does not match";
}
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/PapRestControllerV1.java b/main/src/main/java/org/onap/policy/pap/main/rest/PapRestControllerV1.java
index fb5d2d89..ccdebc33 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/PapRestControllerV1.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/PapRestControllerV1.java
@@ -100,7 +100,7 @@ public class PapRestControllerV1 {
*/
public ResponseBuilder addVersionControlHeaders(ResponseBuilder respBuilder) {
return respBuilder.header(VERSION_MINOR_NAME, "0").header(VERSION_PATCH_NAME, "0").header(VERSION_LATEST_NAME,
- "1.0.0");
+ API_VERSION);
}
/**
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/PapRestServer.java b/main/src/main/java/org/onap/policy/pap/main/rest/PapRestServer.java
index 01c33611..87db6ad3 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/PapRestServer.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/PapRestServer.java
@@ -66,7 +66,7 @@ public class PapRestServer implements Startable {
servers = HttpServletServer.factory.build(getServerProperties());
for (final HttpServletServer server : servers) {
if (server.isAaf()) {
- server.addFilterClass(null, PapAafFilter.class.getCanonicalName());
+ server.addFilterClass(null, PapAafFilter.class.getName());
}
server.start();
}
@@ -93,12 +93,12 @@ public class PapRestServer implements Startable {
props.setProperty(svcpfx + PolicyEndPointProperties.PROPERTY_HTTP_PORT_SUFFIX,
Integer.toString(restServerParameters.getPort()));
props.setProperty(svcpfx + PolicyEndPointProperties.PROPERTY_HTTP_REST_CLASSES_SUFFIX,
- String.join(",", HealthCheckRestControllerV1.class.getCanonicalName(),
- StatisticsRestControllerV1.class.getCanonicalName(),
- PdpGroupDeployControllerV1.class.getCanonicalName(),
- PdpGroupDeleteControllerV1.class.getCanonicalName(),
- PdpGroupStateChangeControllerV1.class.getCanonicalName(),
- PdpGroupQueryControllerV1.class.getCanonicalName()));
+ String.join(",", HealthCheckRestControllerV1.class.getName(),
+ StatisticsRestControllerV1.class.getName(),
+ PdpGroupDeployControllerV1.class.getName(),
+ PdpGroupDeleteControllerV1.class.getName(),
+ PdpGroupStateChangeControllerV1.class.getName(),
+ PdpGroupQueryControllerV1.class.getName()));
props.setProperty(svcpfx + PolicyEndPointProperties.PROPERTY_MANAGED_SUFFIX, "false");
props.setProperty(svcpfx + PolicyEndPointProperties.PROPERTY_HTTP_SWAGGER_SUFFIX, "true");
props.setProperty(svcpfx + PolicyEndPointProperties.PROPERTY_HTTP_AUTH_USERNAME_SUFFIX,
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupQueryControllerV1.java b/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupQueryControllerV1.java
index 74d6e619..51270f27 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupQueryControllerV1.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupQueryControllerV1.java
@@ -1,6 +1,7 @@
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2019 Nordix Foundation.
+ * Modifications Copyright (C) 2019 AT&T Intellectual Property.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -40,6 +41,8 @@ import javax.ws.rs.core.Response.Status;
import org.apache.commons.lang3.tuple.Pair;
import org.onap.policy.models.base.PfModelException;
import org.onap.policy.models.pdp.concepts.PdpGroups;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Class to provide REST end points for PAP component to query details of all PDP groups.
@@ -48,6 +51,8 @@ import org.onap.policy.models.pdp.concepts.PdpGroups;
*/
public class PdpGroupQueryControllerV1 extends PapRestControllerV1 {
+ private static final Logger LOGGER = LoggerFactory.getLogger(PdpGroupQueryControllerV1.class);
+
private final PdpGroupQueryProvider provider = new PdpGroupQueryProvider();
/**
@@ -89,6 +94,7 @@ public class PdpGroupQueryControllerV1 extends PapRestControllerV1 {
return addLoggingHeaders(addVersionControlHeaders(Response.status(pair.getLeft())), requestId)
.entity(pair.getRight()).build();
} catch (final PfModelException exp) {
+ LOGGER.info("group query failed", exp);
return addLoggingHeaders(
addVersionControlHeaders(Response.status(exp.getErrorResponse().getResponseCode())), requestId)
.entity(exp.getErrorResponse()).build();
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupStateChangeControllerV1.java b/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupStateChangeControllerV1.java
index c9369a23..e739b2fc 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupStateChangeControllerV1.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/PdpGroupStateChangeControllerV1.java
@@ -1,6 +1,7 @@
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2019 Nordix Foundation.
+ * Modifications Copyright (C) 2019 AT&T Intellectual Property.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -43,6 +44,8 @@ import org.apache.commons.lang3.tuple.Pair;
import org.onap.policy.models.base.PfModelException;
import org.onap.policy.models.pap.concepts.PdpGroupStateChangeResponse;
import org.onap.policy.models.pdp.enums.PdpState;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* Class to provide REST end points for PAP component to change state of a PDP group.
@@ -51,6 +54,8 @@ import org.onap.policy.models.pdp.enums.PdpState;
*/
public class PdpGroupStateChangeControllerV1 extends PapRestControllerV1 {
+ private static final Logger LOGGER = LoggerFactory.getLogger(PdpGroupQueryControllerV1.class);
+
private final PdpGroupStateChangeProvider provider = new PdpGroupStateChangeProvider();
/**
@@ -96,6 +101,7 @@ public class PdpGroupStateChangeControllerV1 extends PapRestControllerV1 {
return addLoggingHeaders(addVersionControlHeaders(Response.status(pair.getLeft())), requestId)
.entity(pair.getRight()).build();
} catch (final PfModelException exp) {
+ LOGGER.info("group state-change failed", exp);
return addLoggingHeaders(
addVersionControlHeaders(Response.status(exp.getErrorResponse().getResponseCode())), requestId)
.entity(exp.getErrorResponse()).build();
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java
index 7d47b3e2..c64a0efe 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java
@@ -138,10 +138,7 @@ public class PdpGroupDeleteProvider extends ProviderBase<PdpGroupDeleteResponse>
protected BiFunction<PdpGroup, PdpSubGroup, Boolean> makeUpdater(ToscaPolicy policy) {
ToscaPolicyIdentifier desiredIdent = policy.getIdentifier();
- return (group, subgroup) -> {
-
- // remove the policy from the subgroup
- return subgroup.getPolicies().remove(desiredIdent);
- };
+ // remove the policy from the subgroup
+ return (group, subgroup) -> subgroup.getPolicies().remove(desiredIdent);
}
}
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java
index 3d44a0cd..5fd1213c 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java
@@ -328,8 +328,8 @@ public class PdpGroupDeployProvider extends ProviderBase<PdpGroupDeployResponse>
*/
private <T> boolean updateList(List<T> dblist, List<T> newList, Consumer<List<T>> setter) {
- Set<T> dbTypes = new HashSet<T>(dblist);
- Set<T> newTypes = new HashSet<T>(newList);
+ Set<T> dbTypes = new HashSet<>(dblist);
+ Set<T> newTypes = new HashSet<>(newList);
if (dbTypes.equals(newTypes)) {
return false;
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/ProviderBase.java b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/ProviderBase.java
index b7575df3..999941f2 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/ProviderBase.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/ProviderBase.java
@@ -179,7 +179,7 @@ public abstract class ProviderBase<R extends SimpleResponse> {
BiFunction<PdpGroup, PdpSubGroup, Boolean> updater = makeUpdater(policy);
for (PdpGroup group : groups) {
- upgradeGroup(data, policy, group, updater);
+ upgradeGroup(data, group, updater);
}
}
@@ -212,13 +212,11 @@ public abstract class ProviderBase<R extends SimpleResponse> {
* Updates a group, assigning a new version number, if it actually changes.
*
* @param data session data
- * @param policy policy to be added to or removed from the group
* @param group the original group, to be updated
* @param updater function to update a group
- * @throws PfModelException if a DAO error occurred
*/
- private void upgradeGroup(SessionData data, ToscaPolicy policy, PdpGroup group,
- BiFunction<PdpGroup, PdpSubGroup, Boolean> updater) throws PfModelException {
+ private void upgradeGroup(SessionData data, PdpGroup group,
+ BiFunction<PdpGroup, PdpSubGroup, Boolean> updater) {
boolean updated = false;
diff --git a/main/src/main/java/org/onap/policy/pap/main/startstop/Main.java b/main/src/main/java/org/onap/policy/pap/main/startstop/Main.java
index f1598165..e8b48e60 100644
--- a/main/src/main/java/org/onap/policy/pap/main/startstop/Main.java
+++ b/main/src/main/java/org/onap/policy/pap/main/startstop/Main.java
@@ -40,6 +40,8 @@ import org.slf4j.LoggerFactory;
*/
public class Main {
+ private static final String START_FAILED = "start of policy pap service failed";
+
private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);
private PapActivator activator;
@@ -66,7 +68,7 @@ public class Main {
// Validate that the arguments are sane
arguments.validate();
} catch (final PolicyPapException e) {
- LOGGER.error("start of policy pap service failed", e);
+ LOGGER.error(START_FAILED, e);
return;
}
@@ -74,7 +76,7 @@ public class Main {
try {
parameterGroup = new PapParameterHandler().getParameters(arguments);
} catch (final Exception e) {
- LOGGER.error("start of policy pap service failed", e);
+ LOGGER.error(START_FAILED, e);
return;
}
@@ -86,7 +88,7 @@ public class Main {
props.load(stream);
}
} catch (final Exception e) {
- LOGGER.error("start of policy pap service failed", e);
+ LOGGER.error(START_FAILED, e);
return;
}
@@ -94,7 +96,7 @@ public class Main {
try {
new PapDatabaseInitializer().initializePapDatabase(parameterGroup.getDatabaseProviderParameters());
} catch (final PolicyPapException exp) {
- LOGGER.error("start of policy pap service failed, used parameters are {}", Arrays.toString(args), exp);
+ LOGGER.error(START_FAILED + ", used parameters are {}", Arrays.toString(args), exp);
return;
}
diff --git a/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java b/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java
index f34d13ad..8f3583e1 100644
--- a/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java
+++ b/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java
@@ -135,12 +135,12 @@ public class PapActivator extends ServiceManagerContainer {
() -> msgDispatcher.unregister(PdpMessageType.PDP_STATUS.name()));
addAction("Message Dispatcher",
- () -> registerMsgDispatcher(),
- () -> unregisterMsgDispatcher());
+ this::registerMsgDispatcher,
+ this::unregisterMsgDispatcher);
addAction("topics",
- () -> TopicEndpoint.manager.start(),
- () -> TopicEndpoint.manager.shutdown());
+ TopicEndpoint.manager::start,
+ TopicEndpoint.manager::shutdown);
addAction("PAP statistics",
() -> Registry.register(PapConstants.REG_STATISTICS_MANAGER, new PapStatisticsManager()),
@@ -183,12 +183,8 @@ public class PapActivator extends ServiceManagerContainer {
() -> Registry.unregister(PapConstants.REG_PDP_MODIFY_MAP));
addAction("Create REST server",
- () -> {
- restServer = new PapRestServer(papParameterGroup.getRestServerParameters());
- },
- () -> {
- restServer = null;
- });
+ () -> restServer = new PapRestServer(papParameterGroup.getRestServerParameters()),
+ () -> restServer = null);
addAction("REST server",
() -> restServer.start(),
diff --git a/main/src/main/java/org/onap/policy/pap/main/startstop/PapCommandLineArguments.java b/main/src/main/java/org/onap/policy/pap/main/startstop/PapCommandLineArguments.java
index b0bbfd8a..fd728d28 100644
--- a/main/src/main/java/org/onap/policy/pap/main/startstop/PapCommandLineArguments.java
+++ b/main/src/main/java/org/onap/policy/pap/main/startstop/PapCommandLineArguments.java
@@ -138,7 +138,7 @@ public class PapCommandLineArguments {
}
if (commandLine.hasOption('h')) {
- return help(Main.class.getCanonicalName());
+ return help(Main.class.getName());
}
if (commandLine.hasOption('v')) {
diff --git a/main/src/test/java/org/onap/policy/pap/main/parameters/CommonTestData.java b/main/src/test/java/org/onap/policy/pap/main/parameters/CommonTestData.java
index e7ffce07..10e500fb 100644
--- a/main/src/test/java/org/onap/policy/pap/main/parameters/CommonTestData.java
+++ b/main/src/test/java/org/onap/policy/pap/main/parameters/CommonTestData.java
@@ -170,7 +170,7 @@ public class CommonTestData {
public Map<String, Object> getPolicyModelsProviderParametersMap() {
final Map<String, Object> map = new TreeMap<>();
map.put("name", PolicyModelsProviderParameters.class.getSimpleName());
- map.put("implementation", DatabasePolicyModelsProviderImpl.class.getCanonicalName());
+ map.put("implementation", DatabasePolicyModelsProviderImpl.class.getName());
map.put("databaseDriver", "org.h2.Driver");
map.put("databaseUrl", "jdbc:h2:mem:testdb");
map.put("databaseUser", "policy");
diff --git a/main/src/test/resources/simpleDeploy/createGroupNewPolicy.json b/main/src/test/resources/simpleDeploy/createGroupNewPolicy.json
index 285db315..9aa54cb9 100644
--- a/main/src/test/resources/simpleDeploy/createGroupNewPolicy.json
+++ b/main/src/test/resources/simpleDeploy/createGroupNewPolicy.json
@@ -4,7 +4,7 @@
"name": "policyB",
"version": "1.2.3",
"type": "typeA",
- "typeVersion": "100.2.3"
+ "type_version": "100.2.3"
}
]
}
diff --git a/main/src/test/resources/simpleDeploy/daoPolicyList.json b/main/src/test/resources/simpleDeploy/daoPolicyList.json
index 93ee9146..873cb711 100644
--- a/main/src/test/resources/simpleDeploy/daoPolicyList.json
+++ b/main/src/test/resources/simpleDeploy/daoPolicyList.json
@@ -4,7 +4,7 @@
"name": "policyA",
"version": "1.2.3",
"type": "typeA",
- "typeVersion": "100.2.3"
+ "type_version": "100.2.3"
}
]
}
diff --git a/main/src/test/resources/simpleDeploy/policy.json b/main/src/test/resources/simpleDeploy/policy.json
index 7786aab7..084aafcc 100644
--- a/main/src/test/resources/simpleDeploy/policy.json
+++ b/main/src/test/resources/simpleDeploy/policy.json
@@ -2,5 +2,5 @@
"name": "policyA",
"version": "1.2.3",
"type": "typeA",
- "typeVersion": "100.2.3"
+ "type_version": "100.2.3"
}
diff --git a/main/src/test/resources/simpleDeploy/upgradeGroupDao.json b/main/src/test/resources/simpleDeploy/upgradeGroupDao.json
index 278b69a6..bee81bed 100644
--- a/main/src/test/resources/simpleDeploy/upgradeGroupDao.json
+++ b/main/src/test/resources/simpleDeploy/upgradeGroupDao.json
@@ -47,7 +47,7 @@
"name": "policyA",
"version": "1.2.3",
"type": "typeA",
- "typeVersion": "100.2.3"
+ "type_version": "100.2.3"
}
]
},
diff --git a/main/src/test/resources/simpleDeploy/upgradeGroupPolicy2.json b/main/src/test/resources/simpleDeploy/upgradeGroupPolicy2.json
index 3a13d0c3..54201b94 100644
--- a/main/src/test/resources/simpleDeploy/upgradeGroupPolicy2.json
+++ b/main/src/test/resources/simpleDeploy/upgradeGroupPolicy2.json
@@ -4,7 +4,7 @@
"name": "policyB",
"version": "1.2.3",
"type": "typeB",
- "typeVersion": "100.2.3"
+ "type_version": "100.2.3"
}
]
}
diff --git a/main/src/test/resources/simpleDeploy/upgradeGroupPolicy3.json b/main/src/test/resources/simpleDeploy/upgradeGroupPolicy3.json
index bf5602ea..57a8f849 100644
--- a/main/src/test/resources/simpleDeploy/upgradeGroupPolicy3.json
+++ b/main/src/test/resources/simpleDeploy/upgradeGroupPolicy3.json
@@ -4,7 +4,7 @@
"name": "policyC",
"version": "1.2.3",
"type": "typeC",
- "typeVersion": "100.2.3"
+ "type_version": "100.2.3"
}
]
}
diff --git a/main/src/test/resources/simpleDeploy/upgradeGroupPolicy4.json b/main/src/test/resources/simpleDeploy/upgradeGroupPolicy4.json
index 3c0fb72f..8b7c96c5 100644
--- a/main/src/test/resources/simpleDeploy/upgradeGroupPolicy4.json
+++ b/main/src/test/resources/simpleDeploy/upgradeGroupPolicy4.json
@@ -4,7 +4,7 @@
"name": "policyD",
"version": "1.2.3",
"type": "typeA",
- "typeVersion": "100.2.3"
+ "type_version": "100.2.3"
}
]
}