summaryrefslogtreecommitdiffstats
path: root/main
diff options
context:
space:
mode:
authorrameshiyer27 <ramesh.murugan.iyer@est.tech>2024-01-29 17:51:52 +0000
committerrameshiyer27 <ramesh.murugan.iyer@est.tech>2024-02-09 10:29:59 +0000
commitdfc5d564659ea5faccceaf5ecb7eb6fbc54bd701 (patch)
treedb9dcf25f3daf387aba6940f93ddb1e40bf833b2 /main
parent875d5ca25cf09bbf80a8493639f2abfc501fc844 (diff)
Remove Dmaap from PAP
Issue-ID: POLICY-4402 Signed-off-by: rameshiyer27 <ramesh.murugan.iyer@est.tech> Change-Id: Ib1715bde8b4d0ca78b3c74c62784d5579900c2d4
Diffstat (limited to 'main')
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/KafkaGetTopicResponse.java (renamed from main/src/main/java/org/onap/policy/pap/main/rest/DmaapGetTopicResponse.java)5
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/PolicyComponentsHealthCheckProvider.java18
-rw-r--r--main/src/main/resources/application.yaml20
-rw-r--r--main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java20
-rw-r--r--main/src/test/java/org/onap/policy/pap/main/rest/e2e/End2EndContext.java4
-rw-r--r--main/src/test/resources/application-test-e2e.yaml4
-rw-r--r--main/src/test/resources/parameters/MinimumParameters.json8
-rw-r--r--main/src/test/resources/parameters/PapConfigParameters.json4
-rw-r--r--main/src/test/resources/parameters/PapConfigParametersStd.json8
-rw-r--r--main/src/test/resources/parameters/PapConfigParameters_Postgres.json6
10 files changed, 49 insertions, 48 deletions
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/DmaapGetTopicResponse.java b/main/src/main/java/org/onap/policy/pap/main/rest/KafkaGetTopicResponse.java
index 82886509..dd63a507 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/DmaapGetTopicResponse.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/KafkaGetTopicResponse.java
@@ -1,6 +1,7 @@
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2021 Bell Canada. All rights reserved.
+ * Modifications Copyright (C) 2024 Nordix Foundation.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -26,12 +27,12 @@ import lombok.Setter;
import lombok.ToString;
/**
- * Class to capture get topic response from dmaap.
+ * Class to capture get topic response from kafka.
*/
@Getter
@Setter
@ToString
-public class DmaapGetTopicResponse {
+public class KafkaGetTopicResponse {
private List<String> topics;
}
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/PolicyComponentsHealthCheckProvider.java b/main/src/main/java/org/onap/policy/pap/main/rest/PolicyComponentsHealthCheckProvider.java
index 02d27605..32d43143 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/PolicyComponentsHealthCheckProvider.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/PolicyComponentsHealthCheckProvider.java
@@ -1,6 +1,6 @@
/*-
* ============LICENSE_START=======================================================
- * Copyright (C) 2019-2020, 2022-2023 Nordix Foundation.
+ * Copyright (C) 2019-2020, 2022-2024 Nordix Foundation.
* Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
* Modifications Copyright (C) 2020-2022 Bell Canada. All rights reserved.
* ================================================================================
@@ -204,8 +204,8 @@ public class PolicyComponentsHealthCheckProvider {
HealthCheckReport clientReport;
try {
Response resp = httpClient.get();
- if (httpClient.getName().equalsIgnoreCase("dmaap")) {
- clientReport = verifyDmaapClient(httpClient, resp);
+ if (httpClient.getName().equalsIgnoreCase("kafka")) {
+ clientReport = verifyKafkaClient(httpClient, resp);
} else {
clientReport = replaceIpWithHostname(resp.readEntity(HealthCheckReport.class), httpClient.getBaseUrl());
}
@@ -244,12 +244,12 @@ public class PolicyComponentsHealthCheckProvider {
return report;
}
- private HealthCheckReport verifyDmaapClient(HttpClient httpClient, Response resp) {
- DmaapGetTopicResponse dmaapResponse = resp.readEntity(DmaapGetTopicResponse.class);
- var topicVerificationStatus = (dmaapResponse.getTopics() != null
- && dmaapResponse.getTopics().contains(topicPolicyPdpPap));
- String message = (topicVerificationStatus ? "PAP to DMaaP connection check is successful"
- : "PAP to DMaaP connection check failed");
+ private HealthCheckReport verifyKafkaClient(HttpClient httpClient, Response resp) {
+ KafkaGetTopicResponse kafkaResponse = resp.readEntity(KafkaGetTopicResponse.class);
+ var topicVerificationStatus = (kafkaResponse.getTopics() != null
+ && kafkaResponse.getTopics().contains(topicPolicyPdpPap));
+ String message = (topicVerificationStatus ? "PAP to Kafka connection check is successful"
+ : "PAP to Kafka connection check failed");
int code = (topicVerificationStatus ? resp.getStatus() : 503);
return createHealthCheckReport(httpClient.getName(), httpClient.getBaseUrl(), code,
topicVerificationStatus, message);
diff --git a/main/src/main/resources/application.yaml b/main/src/main/resources/application.yaml
index 2a3d1620..12716072 100644
--- a/main/src/main/resources/application.yaml
+++ b/main/src/main/resources/application.yaml
@@ -43,25 +43,25 @@ pap:
topicSources:
- topic: ${pap.topic.pdp-pap.name}
servers:
- - message-router
- topicCommInfrastructure: dmaap
+ - kafka
+ topicCommInfrastructure: NOOP
fetchTimeout: 15000
- topic: ${pap.topic.heartbeat.name}
effectiveTopic: ${pap.topic.pdp-pap.name}
consumerGroup: policy-pap
servers:
- - message-router
- topicCommInfrastructure: dmaap
+ - kafka
+ topicCommInfrastructure: NOOP
fetchTimeout: 15000
topicSinks:
- topic: ${pap.topic.pdp-pap.name}
servers:
- - message-router
- topicCommInfrastructure: dmaap
+ - kafka
+ topicCommInfrastructure: NOOP
- topic: ${pap.topic.notification.name}
servers:
- - message-router
- topicCommInfrastructure: dmaap
+ - kafka
+ topicCommInfrastructure: NOOP
healthCheckRestClientParameters:
- clientName: api
hostname: policy-api
@@ -77,8 +77,8 @@ pap:
password: zb!XztG34
useHttps: true
basePath: healthcheck
- - clientName: dmaap
- hostname: message-router
+ - clientName: kafka
+ hostname: kafka
port: 3905
useHttps: true
basePath: topics
diff --git a/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java b/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
index 41597218..60712c06 100644
--- a/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
+++ b/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
@@ -1,6 +1,6 @@
/*-
* ============LICENSE_START=======================================================
- * Copyright (C) 2020, 2022-2023 Nordix Foundation.
+ * Copyright (C) 2020, 2022-2024 Nordix Foundation.
* Modifications Copyright (C) 2020-2021 AT&T Corp.
* Modifications Copyright (C) 2020-2022 Bell Canada. All rights reserved.
* ================================================================================
@@ -136,10 +136,10 @@ class TestPolicyComponentsHealthCheckProvider {
when(response2.readEntity(HealthCheckReport.class)).thenReturn(createReport(HttpURLConnection.HTTP_OK, true));
when(client2.get()).thenReturn(response2);
- when(client3.getName()).thenReturn("dmaap");
- when(client3.getBaseUrl()).thenReturn("message-router");
+ when(client3.getName()).thenReturn("kafka");
+ when(client3.getBaseUrl()).thenReturn("kafka");
when(response3.getStatus()).thenReturn(HttpURLConnection.HTTP_OK);
- when(response3.readEntity(DmaapGetTopicResponse.class)).thenReturn(createDmaapResponse());
+ when(response3.readEntity(KafkaGetTopicResponse.class)).thenReturn(createKafkaResponse());
when(client3.get()).thenReturn(response3);
List<HttpClient> clients = new ArrayList<>();
clients.add(client1);
@@ -193,17 +193,17 @@ class TestPolicyComponentsHealthCheckProvider {
assertFalse(report2.isHealthy());
when(response3.getStatus()).thenReturn(HttpURLConnection.HTTP_INTERNAL_ERROR);
- when(response3.readEntity(DmaapGetTopicResponse.class)).thenReturn(null);
+ when(response3.readEntity(KafkaGetTopicResponse.class)).thenReturn(null);
Map<String, Object> result3 = callFetchPolicyComponentsHealthStatus();
assertFalse((Boolean) result3.get(HEALTHY));
- HealthCheckReport report3 = (HealthCheckReport) result3.get("dmaap");
+ HealthCheckReport report3 = (HealthCheckReport) result3.get("kafka");
assertFalse(report3.isHealthy());
when(response3.getStatus()).thenReturn(HttpURLConnection.HTTP_OK);
- when(response3.readEntity(DmaapGetTopicResponse.class)).thenReturn(new DmaapGetTopicResponse());
+ when(response3.readEntity(KafkaGetTopicResponse.class)).thenReturn(new KafkaGetTopicResponse());
Map<String, Object> result4 = callFetchPolicyComponentsHealthStatus();
assertFalse((Boolean) result4.get(HEALTHY));
- HealthCheckReport report4 = (HealthCheckReport) result4.get("dmaap");
+ HealthCheckReport report4 = (HealthCheckReport) result4.get("kafka");
assertFalse(report4.isHealthy());
}
@@ -260,8 +260,8 @@ class TestPolicyComponentsHealthCheckProvider {
}
}
- private DmaapGetTopicResponse createDmaapResponse() {
- DmaapGetTopicResponse response = new DmaapGetTopicResponse();
+ private KafkaGetTopicResponse createKafkaResponse() {
+ KafkaGetTopicResponse response = new KafkaGetTopicResponse();
response.setTopics(List.of("POLICY-PDP-PAP"));
return response;
}
diff --git a/main/src/test/java/org/onap/policy/pap/main/rest/e2e/End2EndContext.java b/main/src/test/java/org/onap/policy/pap/main/rest/e2e/End2EndContext.java
index c0c98adc..c6a67483 100644
--- a/main/src/test/java/org/onap/policy/pap/main/rest/e2e/End2EndContext.java
+++ b/main/src/test/java/org/onap/policy/pap/main/rest/e2e/End2EndContext.java
@@ -3,7 +3,7 @@
* ONAP PAP
* ================================================================================
* Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
- * Modifications Copyright (C) 2022-2023 Nordix Foundation.
+ * Modifications Copyright (C) 2022-2024 Nordix Foundation.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -144,7 +144,7 @@ public class End2EndContext {
}
/**
- * Starts the threads that read the "DMaaP" queues..
+ * Starts the threads that read the "kafka" queues.
*/
public void startThreads() {
if (running) {
diff --git a/main/src/test/resources/application-test-e2e.yaml b/main/src/test/resources/application-test-e2e.yaml
index 23920f1d..01f35758 100644
--- a/main/src/test/resources/application-test-e2e.yaml
+++ b/main/src/test/resources/application-test-e2e.yaml
@@ -63,8 +63,8 @@ pap:
password: zb!XztG34
useHttps: true
basePath: healthcheck
- - clientName: dmaap
- hostname: message-router
+ - clientName: kafka
+ hostname: kafka
port: 3905
useHttps: true
basePath: topics
diff --git a/main/src/test/resources/parameters/MinimumParameters.json b/main/src/test/resources/parameters/MinimumParameters.json
index 80125305..bf2f4b54 100644
--- a/main/src/test/resources/parameters/MinimumParameters.json
+++ b/main/src/test/resources/parameters/MinimumParameters.json
@@ -29,13 +29,13 @@
"topicParameterGroup": {
"topicSources" : [{
"topic" : "POLICY-PDP-PAP",
- "servers" : [ "message-router" ],
- "topicCommInfrastructure" : "dmaap"
+ "servers" : [ "kafka" ],
+ "topicCommInfrastructure" : "NOOP"
}],
"topicSinks" : [{
"topic" : "POLICY-PDP-PAP",
- "servers" : [ "message-router" ],
- "topicCommInfrastructure" : "dmaap"
+ "servers" : [ "kafka" ],
+ "topicCommInfrastructure" : "NOOP"
}]
},
"healthCheckRestClientParameters":[{
diff --git a/main/src/test/resources/parameters/PapConfigParameters.json b/main/src/test/resources/parameters/PapConfigParameters.json
index debdc47c..b7604706 100644
--- a/main/src/test/resources/parameters/PapConfigParameters.json
+++ b/main/src/test/resources/parameters/PapConfigParameters.json
@@ -69,8 +69,8 @@
"basePath": "healthcheck"
},
{
- "clientName": "dmaap",
- "hostname": "message-router",
+ "clientName": "kafka",
+ "hostname": "kafka",
"port": 3905,
"useHttps": true,
"basePath": "topics"
diff --git a/main/src/test/resources/parameters/PapConfigParametersStd.json b/main/src/test/resources/parameters/PapConfigParametersStd.json
index 1b5b0eff..b5ad3304 100644
--- a/main/src/test/resources/parameters/PapConfigParametersStd.json
+++ b/main/src/test/resources/parameters/PapConfigParametersStd.json
@@ -31,14 +31,14 @@
"topicParameterGroup": {
"topicSources" : [{
"topic" : "POLICY-PDP-PAP",
- "servers" : [ "message-router" ],
+ "servers" : [ "kafka" ],
"topicCommInfrastructure" : "noop"
},
{
"topic" : "POLICY-HEARTBEAT",
"effectiveTopic": "POLICY-PDP-PAP",
"consumerGroup": "policy-pap",
- "servers" : [ "message-router" ],
+ "servers" : [ "kafka" ],
"topicCommInfrastructure" : "noop"
}],
"topicSinks" : [{
@@ -70,8 +70,8 @@
"basePath": "healthcheck"
},
{
- "clientName": "dmaap",
- "hostname": "message-router",
+ "clientName": "kafka",
+ "hostname": "kafka",
"port": 3905,
"useHttps": true,
"basePath": "topics"
diff --git a/main/src/test/resources/parameters/PapConfigParameters_Postgres.json b/main/src/test/resources/parameters/PapConfigParameters_Postgres.json
index 46d25b10..5f92936a 100644
--- a/main/src/test/resources/parameters/PapConfigParameters_Postgres.json
+++ b/main/src/test/resources/parameters/PapConfigParameters_Postgres.json
@@ -31,16 +31,16 @@
"topicSources" : [{
"topic" : "POLICY-PDP-PAP",
"servers" : [ "localhost:3904" ],
- "topicCommInfrastructure" : "dmaap"
+ "topicCommInfrastructure" : "NOOP"
}],
"topicSinks" : [{
"topic" : "POLICY-PDP-PAP",
"servers" : [ "localhost:3904" ],
- "topicCommInfrastructure" : "dmaap"
+ "topicCommInfrastructure" : "NOOP"
},{
"topic" : "POLICY-NOTIFICATION",
"servers" : [ "localhost:3904" ],
- "topicCommInfrastructure" : "dmaap"
+ "topicCommInfrastructure" : "NOOP"
}]
},
"healthCheckRestClientParameters":[{