diff options
author | FrancescoFioraEst <francesco.fiora@est.tech> | 2023-07-18 13:47:55 +0100 |
---|---|---|
committer | Ramesh Murugan Iyer <ramesh.murugan.iyer@est.tech> | 2023-07-20 08:20:17 +0000 |
commit | 2f0734e78e355122e80d03c0cbd70f2343e9fed2 (patch) | |
tree | acb284136ff3cb9ea5de65f03a8fb2aa01b7db71 /runtime-acm/src/main/java/org/onap | |
parent | 7506262d3f88ed1ce1d0a4d3afeac19f9157c2f6 (diff) |
Fix OFF_LINE issue when Status message upcoming
Issue-ID: POLICY-4770
Change-Id: If5812e689fab5ebfcf3eb23c89dcbd556ad8f331
Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
(cherry picked from commit 1a5a1f51875433be47a697a2f2498a428c23d7e5)
Diffstat (limited to 'runtime-acm/src/main/java/org/onap')
-rwxr-xr-x[-rw-r--r--] | runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java | 14 |
1 files changed, 10 insertions, 4 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 e0d11ed9f..f8bc233e9 100644..100755 --- 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 @@ -76,10 +76,7 @@ public class SupervisionParticipantHandler { if (participantOpt.isPresent()) { var participant = participantOpt.get(); - if (ParticipantState.OFF_LINE.equals(participant.getParticipantState())) { - participant.setParticipantState(ParticipantState.ON_LINE); - participantProvider.saveParticipant(participant); - } + checkOnline(participant); handleRestart(participant.getParticipantId()); } else { var participant = createParticipant(participantRegisterMsg.getParticipantId(), @@ -127,12 +124,21 @@ public class SupervisionParticipantHandler { var participant = createParticipant(participantStatusMsg.getParticipantId(), listToMap(participantStatusMsg.getParticipantSupportedElementType())); participantProvider.saveParticipant(participant); + } else { + checkOnline(participantOpt.get()); } if (!participantStatusMsg.getAutomationCompositionInfoList().isEmpty()) { automationCompositionProvider.upgradeStates(participantStatusMsg.getAutomationCompositionInfoList()); } } + private void checkOnline(Participant participant) { + if (ParticipantState.OFF_LINE.equals(participant.getParticipantState())) { + participant.setParticipantState(ParticipantState.ON_LINE); + participantProvider.saveParticipant(participant); + } + } + private void handleRestart(UUID participantId) { var compositionIds = participantProvider.getCompositionIds(participantId); for (var compositionId : compositionIds) { |