diff options
5 files changed, 25 insertions, 26 deletions
diff --git a/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/EndToEndFeatureTest.java b/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/EndToEndFeatureTest.java index 08c7ebe4..b8970f1f 100644 --- a/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/EndToEndFeatureTest.java +++ b/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/EndToEndFeatureTest.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * ONAP * ================================================================================ - * Copyright (C) 2018-2020 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2018-2021 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -317,7 +317,7 @@ public class EndToEndFeatureTest { /** * Constructor. * - * @param nEvents number of events to be processed + * @param events number of events to be processed */ public Context(int events) { eventCounter = new CountDownLatch(events); diff --git a/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/FeatureTest.java b/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/FeatureTest.java index efab636b..bbd4c19f 100644 --- a/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/FeatureTest.java +++ b/feature-pooling-dmaap/src/test/java/org/onap/policy/drools/pooling/FeatureTest.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * ONAP * ================================================================================ - * Copyright (C) 2018-2020 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2018-2021 AT&T Intellectual Property. All rights reserved. * Modifications Copyright (C) 2020 Nordix Foundation * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); @@ -231,7 +231,7 @@ public class FeatureTest { /** * Constructor. * - * @param nEvents number of events to be processed + * @param events number of events to be processed */ public Context(int events) { @@ -1002,7 +1002,6 @@ public class FeatureTest { /** * Constructor. * - * @param context this manager's context * @param topic the topic * @throws PoolingFeatureException if an error occurs */ diff --git a/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/PersistenceFeature.java b/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/PersistenceFeature.java index efe2a294..3c3e5008 100644 --- a/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/PersistenceFeature.java +++ b/feature-session-persistence/src/main/java/org/onap/policy/drools/persistence/PersistenceFeature.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * feature-session-persistence * ================================================================================ - * Copyright (C) 2017-2020 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2017-2021 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -21,7 +21,6 @@ package org.onap.policy.drools.persistence; import java.io.IOException; -import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.HashMap; @@ -152,7 +151,7 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine @Override public PolicySession.ThreadModel selectThreadModel(PolicySession session) { - PolicyContainer policyContainer = session.getPolicyContainer(); + var policyContainer = session.getPolicyContainer(); if (isPersistenceEnabled(policyContainer, session.getName())) { return new PersistentThreadModel(session, getProperties(policyContainer)); } @@ -291,7 +290,7 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine configureSysProps(); BasicDataSource ds = makeDataSource(getDataSourceProperties()); - DsEmf dsemf = new DsEmf(ds); + var dsemf = new DsEmf(ds); try { EntityManagerFactory emf = dsemf.emf; @@ -306,11 +305,11 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine logger.info( "getPolicySession:session does not exist -- attempt to create one with name {}", name); - Environment env = kieSvcFact.newEnvironment(); + var env = kieSvcFact.newEnvironment(); configureKieEnv(env, emf); - KieSessionConfiguration kieConf = kieSvcFact.newKieSessionConfiguration(); + var kieConf = kieSvcFact.newKieSessionConfiguration(); KieSession kieSession = (desiredSessionId >= 0 @@ -343,13 +342,13 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine * @param kieBaseName the name of the 'KieBase' instance containing this session * @param desiredSessionId id of the desired KieSession * @param env Kie Environment for the session - * @param kConf Kie Configuration for the session + * @param kieConf Kie Configuration for the session * @return the persistent session, or {@code null} if it could not be loaded */ private KieSession loadKieSession( String kieBaseName, long desiredSessionId, Environment env, KieSessionConfiguration kieConf) { try { - KieSession kieSession = + var kieSession = kieSvcFact .getStoreServices() .loadKieSession( @@ -376,7 +375,7 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine * @return a new, persistent session */ private KieSession newKieSession(String kieBaseName, Environment env) { - KieSession kieSession = + var kieSession = kieSvcFact .getStoreServices() .newKieSession(policyContainer.getKieContainer().getKieBase(kieBaseName), null, env); @@ -461,7 +460,7 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine */ private void replaceSession(DroolsSessionConnector conn, String sessnm, KieSession kieSession) { - DroolsSessionEntity sess = new DroolsSessionEntity(); + var sess = new DroolsSessionEntity(); sess.setSessionName(sessnm); sess.setSessionId(kieSession.getIdentifier()); @@ -478,7 +477,7 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine * @return the data source properties */ private Properties getDataSourceProperties() { - Properties props = new Properties(); + var props = new Properties(); props.put("driverClassName", persistProps.getProperty(DroolsPersistenceProperties.DB_DRIVER)); props.put("url", persistProps.getProperty(DroolsPersistenceProperties.DB_URL)); props.put("username", persistProps.getProperty(DroolsPersistenceProperties.DB_USER)); @@ -512,7 +511,7 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine // now do the record deletion try (BasicDataSource ds = makeDataSource(getDataSourceProperties()); - Connection connection = ds.getConnection(); + var connection = ds.getConnection(); PreparedStatement statement = connection.prepareStatement( "DELETE FROM sessioninfo WHERE timestampdiff(second,lastmodificationdate,now()) > ?")) { @@ -542,8 +541,8 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine * @return {@code true} if persistence is enabled for this container, and {@code false} if not */ private boolean isPersistenceEnabled(PolicyContainer container, String sessionName) { - Properties properties = getProperties(container); - boolean rval = false; + var properties = getProperties(container); + var rval = false; if (properties != null) { // fetch the 'type' property @@ -635,7 +634,7 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine String name = session.getName(); // fetch 'minSleepTime' value, and update if defined - String sleepTimeString = getProperty(properties, name, "minSleepTime"); + var sleepTimeString = getProperty(properties, name, "minSleepTime"); if (sleepTimeString != null) { try { minSleepTime = Math.max(1, Integer.valueOf(sleepTimeString)); @@ -733,13 +732,13 @@ public class PersistenceFeature implements PolicySessionFeatureApi, PolicyEngine // set thread local variable session.setPolicySession(); - KieSession kieSession = session.getKieSession(); + var kieSession = session.getKieSession(); long sleepTime = 2 * halfMaxSleepTime; // We want to continue, despite any exceptions that occur // while rules are fired. - boolean cont = true; + var cont = true; while (cont) { try { diff --git a/policy-core/src/test/java/org/onap/policy/drools/core/lock/AlwaysLockBaseTest.java b/policy-core/src/test/java/org/onap/policy/drools/core/lock/AlwaysLockBaseTest.java index 1091b260..b5f7a64c 100644 --- a/policy-core/src/test/java/org/onap/policy/drools/core/lock/AlwaysLockBaseTest.java +++ b/policy-core/src/test/java/org/onap/policy/drools/core/lock/AlwaysLockBaseTest.java @@ -40,6 +40,7 @@ public abstract class AlwaysLockBaseTest<T extends LockImpl> { protected T lock; @Test + @SuppressWarnings("unchecked") public void testSerializable() throws Exception { ByteArrayOutputStream baos = new ByteArrayOutputStream(); try (ObjectOutputStream oos = new ObjectOutputStream(baos)) { diff --git a/policy-management/src/main/java/org/onap/policy/drools/system/internal/LockManager.java b/policy-management/src/main/java/org/onap/policy/drools/system/internal/LockManager.java index eee2a50e..88037bbb 100644 --- a/policy-management/src/main/java/org/onap/policy/drools/system/internal/LockManager.java +++ b/policy-management/src/main/java/org/onap/policy/drools/system/internal/LockManager.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * ONAP * ================================================================================ - * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2019, 2021 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -143,14 +143,14 @@ public abstract class LockManager<T extends FeatureLockImpl> implements PolicyRe boolean waitForLock) { if (hasInstanceChanged()) { - AlwaysFailLock lock = new AlwaysFailLock(resourceId, ownerKey, holdSec, callback); + var lock = new AlwaysFailLock(resourceId, ownerKey, holdSec, callback); lock.notifyUnavailable(); return lock; } T lock = makeLock(LockState.WAITING, resourceId, ownerKey, holdSec, callback); - T existingLock = resource2lock.putIfAbsent(resourceId, lock); + var existingLock = resource2lock.putIfAbsent(resourceId, lock); if (existingLock == null) { logger.debug("added lock to map {}", lock); @@ -192,6 +192,6 @@ public abstract class LockManager<T extends FeatureLockImpl> implements PolicyRe * lost; must not be {@code null} * @return a new lock */ - protected abstract T makeLock(LockState waiting, String resourceId, String ownerKey, int holdSec, + protected abstract T makeLock(LockState state, String resourceId, String ownerKey, int holdSec, LockCallback callback); } |