aboutsummaryrefslogtreecommitdiffstats
path: root/runtime-acm/src/main
diff options
context:
space:
mode:
authorFrancescoFioraEst <francesco.fiora@est.tech>2023-02-23 17:03:24 +0000
committerFrancesco Fiora <francesco.fiora@est.tech>2023-02-24 13:56:09 +0000
commit660e20098d446046a27b03b44bccd069aae5408b (patch)
tree10cebe66be95d227422f51fc8c8923da51368578 /runtime-acm/src/main
parent7dfd781843a2c915a7ba89b676c241ad2e1c88b9 (diff)
Fix ClassCastException in ACM
Fix ClassCastException in ACM when acm-runtime starts after participants. Issue-ID: POLICY-4575 Change-Id: Icef82d3ba7f3847c821362ed063c1cf8e81604c5 Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
Diffstat (limited to 'runtime-acm/src/main')
-rw-r--r--runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java13
1 files changed, 7 insertions, 6 deletions
diff --git a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java
index 6cf75ccb6..c1bfcf07a 100644
--- a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java
+++ b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java
@@ -62,7 +62,8 @@ public class SupervisionParticipantHandler {
@Timed(value = "listener.participant_register", description = "PARTICIPANT_REGISTER messages received")
public void handleParticipantMessage(ParticipantRegister participantRegisterMsg) {
LOGGER.debug("Participant Register received {}", participantRegisterMsg);
- saveParticipantStatus(participantRegisterMsg);
+ saveParticipantStatus(participantRegisterMsg,
+ listToMap(participantRegisterMsg.getParticipantSupportedElementType()));
participantRegisterAckPublisher.send(participantRegisterMsg.getMessageId(),
participantRegisterMsg.getParticipantId());
@@ -98,18 +99,18 @@ public class SupervisionParticipantHandler {
@Timed(value = "listener.participant_status", description = "PARTICIPANT_STATUS messages received")
public void handleParticipantMessage(ParticipantStatus participantStatusMsg) {
LOGGER.debug("Participant Status received {}", participantStatusMsg);
- saveParticipantStatus(participantStatusMsg);
+ saveParticipantStatus(participantStatusMsg,
+ listToMap(participantStatusMsg.getParticipantSupportedElementType()));
}
- private void saveParticipantStatus(ParticipantMessage participantMessage) {
+ private void saveParticipantStatus(ParticipantMessage participantMessage,
+ Map<UUID, ParticipantSupportedElementType> participantSupportedElementType) {
var participantOpt = participantProvider.findParticipant(participantMessage.getParticipantId());
if (participantOpt.isEmpty()) {
- ParticipantRegister registerMessage = (ParticipantRegister) participantMessage;
var participant = new Participant();
participant.setParticipantId(participantMessage.getParticipantId());
- participant.setParticipantSupportedElementTypes(listToMap(registerMessage
- .getParticipantSupportedElementType()));
+ participant.setParticipantSupportedElementTypes(participantSupportedElementType);
participant.setParticipantState(ParticipantState.ON_LINE);
participantProvider.saveParticipant(participant);