diff options
| author |   FrancescoFioraEst <francesco.fiora@est.tech> | 2024-09-25 17:04:00 +0100 |
|---|---|---|
| committer | Francesco Fiora <francesco.fiora@est.tech> | 2024-09-30 09:43:38 +0000 |
| commit | 15302061ba7e9572ed4ea8c3aa0255d01ef07310 (patch) | |
| tree | 94e97d4daafdfd7ed063306377270a5a5017ce6c /models/src/main/java | |
| parent | 6ed514f31be046cf31caeada994e7b9c036b5f90 (diff) | |
Handle timeout as hard timeout
Issue-ID: POLICY-5132
Change-Id: Ic78d346972e955f7700118ffa74be11643a885f0
Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
Diffstat (limited to 'models/src/main/java')
2 files changed, 5 insertions, 0 deletions
diff --git a/models/src/main/java/org/onap/policy/clamp/models/acm/concepts/ParticipantRestartAc.java b/models/src/main/java/org/onap/policy/clamp/models/acm/concepts/ParticipantRestartAc.java index 3312752fa..5d4b8ac77 100644 --- a/models/src/main/java/org/onap/policy/clamp/models/acm/concepts/ParticipantRestartAc.java +++ b/models/src/main/java/org/onap/policy/clamp/models/acm/concepts/ParticipantRestartAc.java @@ -39,6 +39,7 @@ public class ParticipantRestartAc { private DeployState deployState; private LockState lockState; + private StateChangeResult stateChangeResult; private List<AcElementRestart> acElementList = new ArrayList<>(); @@ -51,6 +52,7 @@ public class ParticipantRestartAc { this.automationCompositionId = copyConstructor.automationCompositionId; this.deployState = copyConstructor.deployState; this.lockState = copyConstructor.lockState; + this.stateChangeResult = copyConstructor.stateChangeResult; this.acElementList = PfUtils.mapList(copyConstructor.acElementList, AcElementRestart::new); } } diff --git a/models/src/main/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantSync.java b/models/src/main/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantSync.java index 85b715b86..2780a5b1e 100644 --- a/models/src/main/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantSync.java +++ b/models/src/main/java/org/onap/policy/clamp/models/acm/messages/kafka/participant/ParticipantSync.java @@ -31,6 +31,7 @@ import lombok.ToString; import org.onap.policy.clamp.models.acm.concepts.AcTypeState; import org.onap.policy.clamp.models.acm.concepts.ParticipantDefinition; import org.onap.policy.clamp.models.acm.concepts.ParticipantRestartAc; +import org.onap.policy.clamp.models.acm.concepts.StateChangeResult; import org.onap.policy.models.base.PfUtils; @Getter @@ -50,6 +51,7 @@ public class ParticipantSync extends ParticipantMessage { private Set<UUID> excludeReplicas = new HashSet<>(); private boolean restarting = false; private boolean delete = false; + private StateChangeResult stateChangeResult; /** * Constructor. @@ -72,5 +74,6 @@ public class ParticipantSync extends ParticipantMessage { this.excludeReplicas = new HashSet<>(source.excludeReplicas); this.restarting = source.restarting; this.delete = source.delete; + this.stateChangeResult = source.getStateChangeResult(); } } |