From 96b0e2bd8b3180396c3198ef0b0f9445dc1af727 Mon Sep 17 00:00:00 2001 From: FrancescoFioraEst Date: Fri, 21 Jun 2024 16:19:38 +0100 Subject: Fix registration flow MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * set replicaId in RegisterAck message * ParticipantRegisterAckPublisher and ParticipantRegisterAckListener should be used with sync topic Issue-ID: POLICY-5060 Change-Id: I1292d636ea79055e902ec3d68108a28fbd80afdc Signed-off-by: FrancescoFioraEst --- .../acm/runtime/supervision/SupervisionParticipantHandler.java | 2 +- .../supervision/comm/ParticipantRegisterAckPublisher.java | 9 ++++++++- 2 files changed, 9 insertions(+), 2 deletions(-) (limited to 'runtime-acm/src/main') diff --git a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java index 4c8c5815c..3c93a3571 100644 --- a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java +++ b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandler.java @@ -81,7 +81,7 @@ public class SupervisionParticipantHandler { participantRegisterMsg.getParticipantSupportedElementType(), true); participantRegisterAckPublisher.send(participantRegisterMsg.getMessageId(), - participantRegisterMsg.getParticipantId()); + participantRegisterMsg.getParticipantId(), participantRegisterMsg.getReplicaId()); } /** diff --git a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/ParticipantRegisterAckPublisher.java b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/ParticipantRegisterAckPublisher.java index d021c57a4..5e073080b 100644 --- a/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/ParticipantRegisterAckPublisher.java +++ b/runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/supervision/comm/ParticipantRegisterAckPublisher.java @@ -36,14 +36,21 @@ public class ParticipantRegisterAckPublisher extends AbstractParticipantAckPubli * * @param responseTo the original request id in the request. * @param participantId the participant Id + * @param replicaId the participant replica Id */ @Timed(value = "publisher.participant_register_ack", description = "PARTICIPANT_REGISTER_ACK messages published") - public void send(UUID responseTo, UUID participantId) { + public void send(UUID responseTo, UUID participantId, UUID replicaId) { var message = new ParticipantRegisterAck(); message.setParticipantId(participantId); + message.setReplicaId(replicaId); message.setResponseTo(responseTo); message.setMessage("Participant Register Ack"); message.setResult(true); super.send(message); } + + @Override + public boolean isDefaultTopic() { + return false; + } } -- cgit