commit | 26b698412c89d21a0bb7ff0873ff6072f80ebfcc | [log] [tgz] |
---|---|---|
author | Pamela Dragosh <pd1248@att.com> | Tue Aug 31 14:46:36 2021 +0000 |
committer | Gerrit Code Review <gerrit@onap.org> | Tue Aug 31 14:46:36 2021 +0000 |
tree | 5fb1b635f599b3ce7fd134d6210ac1102e2d4adc | |
parent | 1a2a4b17938f357d9dc0119f5417d5ea9e405467 [diff] | |
parent | 6d566613d2ed18ac571f2a2dd7ac084c569c54b5 [diff] |
Merge "Fixed participant registration ACK"
diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/controlloop/participant/intermediary/handler/ParticipantHandler.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/controlloop/participant/intermediary/handler/ParticipantHandler.java index d3f6c4d..be8ef00 100644 --- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/controlloop/participant/intermediary/handler/ParticipantHandler.java +++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/controlloop/participant/intermediary/handler/ParticipantHandler.java
@@ -248,6 +248,14 @@ public void handleParticipantRegisterAck(ParticipantRegisterAck participantRegisterAckMsg) { LOGGER.debug("ParticipantRegisterAck message received as responseTo {}", participantRegisterAckMsg.getResponseTo()); + if (ParticipantHealthStatus.UNKNOWN.equals(this.healthStatus)) { + this.healthStatus = ParticipantHealthStatus.HEALTHY; + } + + if (ParticipantState.UNKNOWN.equals(this.state)) { + this.state = ParticipantState.PASSIVE; + } + sender.sendParticipantStatus(makeHeartbeat(false)); } /**