Fix continuous sending CONTROL_LOOP_STATE_CHANGE message 58/124558/1
authorFrancescoFioraEst <francesco.fiora@est.tech>
Wed, 29 Sep 2021 10:15:07 +0000 (11:15 +0100)
committerFrancesco Fiora <francesco.fiora@est.tech>
Wed, 29 Sep 2021 10:18:57 +0000 (10:18 +0000)
Issue-ID: POLICY-3687
Change-Id: I41f8cd80d0c3441533891e7edc21e1440028b852
Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
participant/participant-intermediary/src/main/java/org/onap/policy/clamp/controlloop/participant/intermediary/handler/ControlLoopHandler.java

index 40dc901..ac135b0 100644 (file)
@@ -169,7 +169,7 @@ public class ControlLoopHandler {
         var controlLoop = controlLoopMap.get(stateChangeMsg.getControlLoopId());
 
         if (controlLoop == null) {
-            var controlLoopAck = new ControlLoopAck(ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
+            var controlLoopAck = new ControlLoopAck(ParticipantMessageType.CONTROLLOOP_STATECHANGE_ACK);
             controlLoopAck.setParticipantId(participantId);
             controlLoopAck.setParticipantType(participantType);
             controlLoopAck.setMessage("Control loop " + stateChangeMsg.getControlLoopId()
@@ -368,7 +368,7 @@ public class ControlLoopHandler {
     private void handleStateChange(ControlLoop controlLoop, final ControlLoopOrderedState orderedState) {
 
         if (orderedState.equals(controlLoop.getOrderedState())) {
-            var controlLoopAck = new ControlLoopAck(ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
+            var controlLoopAck = new ControlLoopAck(ParticipantMessageType.CONTROLLOOP_STATECHANGE_ACK);
             controlLoopAck.setParticipantId(participantId);
             controlLoopAck.setParticipantType(participantType);
             controlLoopAck.setMessage("Control loop is already in state " + orderedState);