summaryrefslogtreecommitdiffstats
path: root/participant
diff options
context:
space:
mode:
authorsaul.gill <saul.gill@est.tech>2021-08-27 14:11:52 +0100
committersaul.gill <saul.gill@est.tech>2021-08-30 13:43:46 +0100
commit6d566613d2ed18ac571f2a2dd7ac084c569c54b5 (patch)
tree38fbf03c6d506852d64c0f73fa1165faf853608f /participant
parent6d02de6b9ea3f4e6fc588813fd2177c732a2af92 (diff)
Fixed participant registration ACK
Particiapnts now send status message after registration This adds participants to the DB in Runtime Issue-ID: POLICY-3588 Change-Id: Idb62b429a6e2e0047d6946d9718c78560a7cd659 Signed-off-by: saul.gill <saul.gill@est.tech>
Diffstat (limited to 'participant')
-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 66e09e7f6..860df7fa3 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
@@ -226,6 +226,14 @@ public class ParticipantHandler implements Closeable {
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));
}
/**