summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorPamela Dragosh <pd1248@att.com>2021-08-31 14:46:36 +0000
committerGerrit Code Review <gerrit@onap.org>2021-08-31 14:46:36 +0000
commit26b698412c89d21a0bb7ff0873ff6072f80ebfcc (patch)
tree5fb1b635f599b3ce7fd134d6210ac1102e2d4adc
parent1a2a4b17938f357d9dc0119f5417d5ea9e405467 (diff)
parent6d566613d2ed18ac571f2a2dd7ac084c569c54b5 (diff)
Merge "Fixed participant registration ACK"
-rw-r--r--participant/participant-intermediary/src/main/java/org/onap/policy/clamp/controlloop/participant/intermediary/handler/ParticipantHandler.java8
1 files changed, 8 insertions, 0 deletions
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 d3f6c4d25..be8ef0098 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 class ParticipantHandler {
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));
}
/**