aboutsummaryrefslogtreecommitdiffstats
path: root/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java
diff options
context:
space:
mode:
authorjhh <jorge.hernandez-herrero@att.com>2021-05-07 18:09:13 -0500
committerjhh <jorge.hernandez-herrero@att.com>2021-05-07 18:09:13 -0500
commit16a9a1018dd6e9390543a27970174d8fd00a68bd (patch)
tree0c779c0674aef86ff6ceb1a1e7d9dade5783c115 /policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java
parentc2e25b77402244fdc9f443628ec127e03606c9f6 (diff)
sonars policy-utils and feature-lifecycle
Issue-ID: POLICY-3289 Signed-off-by: jhh <jorge.hernandez-herrero@att.com> Change-Id: Iaf7423f840fb39a27c3e5fd293159d1336d5557a
Diffstat (limited to 'policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java')
-rw-r--r--policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java54
1 files changed, 21 insertions, 33 deletions
diff --git a/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java b/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java
index 6ddcc364..3bd339a2 100644
--- a/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java
+++ b/policy-management/src/main/java/org/onap/policy/drools/controller/internal/MavenDroolsController.java
@@ -34,7 +34,6 @@ import org.kie.api.definition.KiePackage;
import org.kie.api.definition.rule.Query;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.rule.FactHandle;
-import org.kie.api.runtime.rule.QueryResults;
import org.kie.api.runtime.rule.QueryResultsRow;
import org.onap.policy.common.endpoints.event.comm.TopicSink;
import org.onap.policy.common.gson.annotation.GsonJsonIgnore;
@@ -71,7 +70,7 @@ public class MavenDroolsController implements DroolsController {
/**
* logger.
*/
- private static Logger logger = LoggerFactory.getLogger(MavenDroolsController.class);
+ private static final Logger logger = LoggerFactory.getLogger(MavenDroolsController.class);
/**
* Policy Container, the access object to the policy-core layer.
@@ -262,7 +261,7 @@ public class MavenDroolsController implements DroolsController {
for (TopicCoderFilterConfiguration coderConfig: coderConfigurations) {
String topic = coderConfig.getTopic();
- CustomGsonCoder customGsonCoder = getCustomCoder(coderConfig);
+ var customGsonCoder = getCustomCoder(coderConfig);
List<PotentialCoderFilter> coderFilters = coderConfig.getCoderFilters();
if (coderFilters == null || coderFilters.isEmpty()) {
@@ -301,7 +300,7 @@ public class MavenDroolsController implements DroolsController {
}
private CustomGsonCoder getCustomCoder(TopicCoderFilterConfiguration coderConfig) {
- CustomGsonCoder customGsonCoder = coderConfig.getCustomGsonCoder();
+ var customGsonCoder = coderConfig.getCustomGsonCoder();
if (customGsonCoder != null
&& customGsonCoder.getClassContainer() != null
&& !customGsonCoder.getClassContainer().isEmpty()) {
@@ -745,8 +744,8 @@ public class MavenDroolsController implements DroolsController {
Map<String, Integer> classNames = new HashMap<>();
- PolicySession session = getSession(sessionName);
- KieSession kieSession = session.getKieSession();
+ var session = getSession(sessionName);
+ var kieSession = session.getKieSession();
Collection<FactHandle> facts = kieSession.getFactHandles();
for (FactHandle fact : facts) {
@@ -775,8 +774,7 @@ public class MavenDroolsController implements DroolsController {
public long factCount(String sessionName) {
validateSessionName(sessionName);
- PolicySession session = getSession(sessionName);
- return session.getKieSession().getFactCount();
+ return getSession(sessionName).getKieSession().getFactCount();
}
@Override
@@ -793,8 +791,8 @@ public class MavenDroolsController implements DroolsController {
throw new IllegalArgumentException("Class cannot be fetched in model's classloader: " + className);
}
- PolicySession session = getSession(sessionName);
- KieSession kieSession = session.getKieSession();
+ var session = getSession(sessionName);
+ var kieSession = session.getKieSession();
List<Object> factObjects = new ArrayList<>();
@@ -835,14 +833,14 @@ public class MavenDroolsController implements DroolsController {
throw new IllegalArgumentException("Invalid Queried Entity: " + queriedEntity);
}
- PolicySession session = getSession(sessionName);
- KieSession kieSession = session.getKieSession();
+ var session = getSession(sessionName);
+ var kieSession = session.getKieSession();
validateQueryName(kieSession, queryName);
List<Object> factObjects = new ArrayList<>();
- QueryResults queryResults = kieSession.getQueryResults(queryName, queryParams);
+ var queryResults = kieSession.getQueryResults(queryName, queryParams);
for (QueryResultsRow row : queryResults) {
try {
factObjects.add(row.get(queriedEntity));
@@ -871,11 +869,11 @@ public class MavenDroolsController implements DroolsController {
@Override
public <T> boolean delete(@NonNull String sessionName, @NonNull T objFact) {
- KieSession kieSession = getSession(sessionName).getKieSession();
+ var kieSession = getSession(sessionName).getKieSession();
// try first to get the object to delete first by reference
- FactHandle quickFact = kieSession.getFactHandle(objFact);
+ var quickFact = kieSession.getFactHandle(objFact);
if (quickFact != null) {
logger.info("Fast delete of {} from {}", objFact, sessionName);
kieSession.delete(quickFact);
@@ -906,10 +904,10 @@ public class MavenDroolsController implements DroolsController {
@Override
public <T> boolean delete(@NonNull String sessionName, @NonNull Class<T> fact) {
- PolicySession session = getSession(sessionName);
- KieSession kieSession = session.getKieSession();
+ var session = getSession(sessionName);
+ var kieSession = session.getKieSession();
- boolean success = true;
+ var success = true;
Collection<FactHandle> factHandles = kieSession.getFactHandles(new ClassObjectFilter(fact));
for (FactHandle factHandle : factHandles) {
try {
@@ -929,7 +927,7 @@ public class MavenDroolsController implements DroolsController {
@Override
public <T> boolean exists(@NonNull String sessionName, @NonNull T objFact) {
- KieSession kieSession = getSession(sessionName).getKieSession();
+ var kieSession = getSession(sessionName).getKieSession();
if (kieSession.getFactHandle(objFact) != null) {
return true;
}
@@ -965,7 +963,7 @@ public class MavenDroolsController implements DroolsController {
@Override
public Object[] getRecentSourceEvents() {
synchronized (this.recentSourceEvents) {
- Object[] events = new Object[recentSourceEvents.size()];
+ var events = new Object[recentSourceEvents.size()];
return recentSourceEvents.toArray(events);
}
}
@@ -978,7 +976,7 @@ public class MavenDroolsController implements DroolsController {
@Override
public String[] getRecentSinkEvents() {
synchronized (this.recentSinkEvents) {
- String[] events = new String[recentSinkEvents.size()];
+ var events = new String[recentSinkEvents.size()];
return recentSinkEvents.toArray(events);
}
}
@@ -991,18 +989,8 @@ public class MavenDroolsController implements DroolsController {
@Override
public String toString() {
- StringBuilder builder = new StringBuilder();
- builder
- .append("MavenDroolsController [policyContainer=")
- .append(policyContainer.getName())
- .append(":")
- .append(", alive=")
- .append(alive)
- .append(", locked=")
- .append(", modelClassLoaderHash=")
- .append(modelClassLoaderHash)
- .append("]");
- return builder.toString();
+ return "MavenDroolsController [policyContainer=" + policyContainer.getName() + ":" + ", alive=" + alive
+ + ", locked=" + ", modelClassLoaderHash=" + modelClassLoaderHash + "]";
}
// these may be overridden by junit tests