aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/comm/PdpStatusMessageHandler.java1
-rw-r--r--main/src/test/java/org/onap/policy/pap/main/comm/msgdata/RequestImplTest.java54
-rw-r--r--main/src/test/java/org/onap/policy/pap/main/comm/msgdata/StateChangeReqTest.java12
-rw-r--r--main/src/test/java/org/onap/policy/pap/main/rest/e2e/PdpGroupCreateOrUpdateTest.java4
4 files changed, 35 insertions, 36 deletions
diff --git a/main/src/main/java/org/onap/policy/pap/main/comm/PdpStatusMessageHandler.java b/main/src/main/java/org/onap/policy/pap/main/comm/PdpStatusMessageHandler.java
index 696a6942..1426d1cb 100644
--- a/main/src/main/java/org/onap/policy/pap/main/comm/PdpStatusMessageHandler.java
+++ b/main/src/main/java/org/onap/policy/pap/main/comm/PdpStatusMessageHandler.java
@@ -24,7 +24,6 @@ package org.onap.policy.pap.main.comm;
import java.sql.SQLIntegrityConstraintViolationException;
import java.time.Instant;
-import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedList;
diff --git a/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/RequestImplTest.java b/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/RequestImplTest.java
index f4be1409..3d8dc0aa 100644
--- a/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/RequestImplTest.java
+++ b/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/RequestImplTest.java
@@ -77,7 +77,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testRequest_InvalidArgs() {
+ void testRequest_InvalidArgs() {
// null params
assertThatThrownBy(() -> new MyRequest(null, MY_REQ_NAME, msg)).isInstanceOf(NullPointerException.class);
@@ -92,13 +92,13 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testReconfigure2_WrongMsgClass() {
+ void testReconfigure2_WrongMsgClass() {
assertThatIllegalArgumentException().isThrownBy(() -> req.reconfigure(new PdpUpdate()))
.withMessage("expecting PdpStateChange instead of PdpUpdate");
}
@Test
- public void testReconfigure2_NotPublishing() {
+ void testReconfigure2_NotPublishing() {
// replace the message with a new message
req.reconfigure(new PdpStateChange());
@@ -108,7 +108,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testRequestImpl_testReconfigure2_Publishing() {
+ void testRequestImpl_testReconfigure2_Publishing() {
req.startPublishing();
// replace the message with a new message
@@ -135,7 +135,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testIsPublishing() {
+ void testIsPublishing() {
assertFalse(req.isPublishing());
req.startPublishing();
@@ -146,14 +146,14 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testStartPublishingQueueToken_NoListener() {
+ void testStartPublishingQueueToken_NoListener() {
req.setListener(null);
assertThatIllegalStateException().isThrownBy(() -> req.startPublishing())
.withMessage("listener has not been set");
}
@Test
- public void testStartPublishing() {
+ void testStartPublishing() {
req.startPublishing();
assertTrue(req.isPublishing());
@@ -176,7 +176,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testStopPublishing() {
+ void testStopPublishing() {
// not publishing yet
req.stopPublishing();
assertFalse(req.isPublishing());
@@ -197,13 +197,13 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testStopPublishingBoolean_NotPublishing() {
+ void testStopPublishingBoolean_NotPublishing() {
// should not throw an exception
Assertions.assertThatCode(() -> req.stopPublishing()).doesNotThrowAnyException();
}
@Test
- public void testStopPublishingBoolean_TruePublishing() {
+ void testStopPublishingBoolean_TruePublishing() {
req.startPublishing();
req.stopPublishing();
@@ -225,7 +225,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testEnqueue() {
+ void testEnqueue() {
req.startPublishing();
// replace the message with a new message
@@ -267,7 +267,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testResetRetryCount_testBumpRetryCount() {
+ void testResetRetryCount_testBumpRetryCount() {
req = new MyRequest(new RequestParams().setMaxRetryCount(2).setModifyLock(lock).setPdpPublisher(publisher)
.setResponseDispatcher(dispatcher).setTimers(timers), MY_REQ_NAME, msg);
req.setListener(listener);
@@ -287,7 +287,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testProcessResponse() {
+ void testProcessResponse() {
req.startPublishing();
invokeProcessResponse(response);
@@ -298,7 +298,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testProcessResponse_NotPublishing() {
+ void testProcessResponse_NotPublishing() {
// force registration with the dispatcher - needed by invokeProcessResponse(response)
req.startPublishing();
req.stopPublishing();
@@ -310,7 +310,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testProcessResponse_WrongRequest() {
+ void testProcessResponse_WrongRequest() {
req.startPublishing();
response.getResponse().setResponseTo(DIFFERENT);
@@ -323,7 +323,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testProcessResponse_ResponseFailed() {
+ void testProcessResponse_ResponseFailed() {
req.startPublishing();
response.setName(DIFFERENT);
@@ -336,7 +336,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testHandleTimeout() {
+ void testHandleTimeout() {
req.startPublishing();
// remove it from the queue
@@ -352,7 +352,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testHandleTimeout_NotPublishing() {
+ void testHandleTimeout_NotPublishing() {
req.startPublishing();
req.stopPublishing();
@@ -365,7 +365,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testHandleTimeout_RetryExhausted() {
+ void testHandleTimeout_RetryExhausted() {
req.startPublishing();
// exhaust the count
@@ -385,7 +385,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testCheckResponse_Matched() {
+ void testCheckResponse_Matched() {
req.startPublishing();
invokeProcessResponse(response);
@@ -395,7 +395,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testCheckResponse_NullName() {
+ void testCheckResponse_NullName() {
req.startPublishing();
response.setName(null);
@@ -407,7 +407,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testCheckResponse_MismatchedName() {
+ void testCheckResponse_MismatchedName() {
req.startPublishing();
response.setName(DIFFERENT);
@@ -419,7 +419,7 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testCheckResponse_MismatchedNameWithBroadcast() {
+ void testCheckResponse_MismatchedNameWithBroadcast() {
msg.setName(null);
req.startPublishing();
@@ -432,12 +432,12 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testGetName() {
+ void testGetName() {
assertEquals(MY_REQ_NAME, req.getName());
}
@Test
- public void testGetMessage() {
+ void testGetMessage() {
assertSame(msg, req.getMessage());
PdpStateChange msg2 = new PdpStateChange();
@@ -446,12 +446,12 @@ class RequestImplTest extends CommonRequestBase {
}
@Test
- public void testGetParams() {
+ void testGetParams() {
assertSame(reqParams, req.getParams());
}
@Test
- public void testGetUndeployPolicies() {
+ void testGetUndeployPolicies() {
assertTrue(req.getUndeployPolicies().isEmpty());
}
diff --git a/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/StateChangeReqTest.java b/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/StateChangeReqTest.java
index 7cf731d4..1ec23356 100644
--- a/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/StateChangeReqTest.java
+++ b/main/src/test/java/org/onap/policy/pap/main/comm/msgdata/StateChangeReqTest.java
@@ -63,39 +63,39 @@ class StateChangeReqTest extends CommonRequestBase {
}
@Test
- public void testGetMessage() {
+ void testGetMessage() {
assertEquals(MY_REQ_NAME, data.getName());
assertSame(msg, data.getMessage());
}
@Test
- public void testCheckResponse() {
+ void testCheckResponse() {
assertNull(data.checkResponse(response));
}
@Test
- public void testCheckResponse_NullName() {
+ void testCheckResponse_NullName() {
response.setName(null);
assertEquals("null PDP name", data.checkResponse(response));
}
@Test
- public void testCheckResponse_NullMsgName() {
+ void testCheckResponse_NullMsgName() {
msg.setName(null);
assertNull(data.checkResponse(response));
}
@Test
- public void testCheckResponse_MismatchedState() {
+ void testCheckResponse_MismatchedState() {
response.setState(DIFF_STATE);
assertEquals("state is TERMINATED, but expected SAFE", data.checkResponse(response));
}
@Test
- public void testReconfigure() {
+ void testReconfigure() {
// different message type should fail and leave message unchanged
assertFalse(data.reconfigure(new PdpUpdate()));
assertSame(msg, data.getMessage());
diff --git a/main/src/test/java/org/onap/policy/pap/main/rest/e2e/PdpGroupCreateOrUpdateTest.java b/main/src/test/java/org/onap/policy/pap/main/rest/e2e/PdpGroupCreateOrUpdateTest.java
index e7fc09c6..9b4239bb 100644
--- a/main/src/test/java/org/onap/policy/pap/main/rest/e2e/PdpGroupCreateOrUpdateTest.java
+++ b/main/src/test/java/org/onap/policy/pap/main/rest/e2e/PdpGroupCreateOrUpdateTest.java
@@ -88,7 +88,7 @@ class PdpGroupCreateOrUpdateTest extends End2EndBase {
createPdpGroups("createGroups.yaml", "application/yaml");
}
- private void createPdpGroups(String fileName, String mediaType) throws Exception, InterruptedException {
+ private void createPdpGroups(String fileName, String mediaType) throws Exception {
context.addPdp("pdpAA_1", CREATE_SUBGROUP);
context.addPdp("pdpAA_2", CREATE_SUBGROUP);
context.addPdp("pdpAB_1", "pdpTypeB");
@@ -127,7 +127,7 @@ class PdpGroupCreateOrUpdateTest extends End2EndBase {
}
@Test
- public void testCreateAndUpdate_MultipleGroups() throws Exception {
+ void testCreateAndUpdate_MultipleGroups() throws Exception {
Invocation.Builder invocationBuilderForGroupUpdate = sendRequest(CREATEORUPDATE_GROUPS_ENDPOINT);