From a85118152983dbc53ce1d0e14712bc66c4177f65 Mon Sep 17 00:00:00 2001 From: "saul.gill" Date: Wed, 15 Feb 2023 12:39:43 +0000 Subject: Add undeploy on deregister (acm-side) State of Ac Elements associated with participant changed on deregister Issue-ID: POLICY-4499 Change-Id: I54265c13deebd77d654fb843a33f7267d4276b76 Signed-off-by: saul.gill --- .../clamp/acm/runtime/supervision/SupervisionParticipantHandler.java | 1 + .../clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java | 1 + 2 files changed, 2 insertions(+) (limited to 'runtime-acm') 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 75fed71e0..6cf75ccb6 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 @@ -83,6 +83,7 @@ public class SupervisionParticipantHandler { var participant = participantOpt.get(); participant.setParticipantState(ParticipantState.OFF_LINE); participantProvider.updateParticipant(participant); + participantProvider.resetParticipantAcElementState(participant.getParticipantId()); } participantDeregisterAckPublisher.send(participantDeregisterMsg.getMessageId()); diff --git a/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java b/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java index f47e2372a..246ba7dc7 100644 --- a/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java +++ b/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java @@ -57,6 +57,7 @@ class SupervisionParticipantHandlerTest { handler.handleParticipantMessage(participantDeregisterMessage); verify(participantProvider).updateParticipant(any()); + verify(participantProvider).resetParticipantAcElementState(any()); verify(participantDeregisterAckPublisher).send(participantDeregisterMessage.getMessageId()); } -- cgit 1.2.3-korg