diff options
author | 2024-06-21 16:19:38 +0100 | |
---|---|---|
committer | 2024-06-24 11:51:54 +0000 | |
commit | 96b0e2bd8b3180396c3198ef0b0f9445dc1af727 (patch) | |
tree | 6e50f3c8c06c7306759c248faca0762a0da23b6a /participant/participant-intermediary/src/main/java | |
parent | 98285f381934f8b419a2bb123ea4a084fdd7b540 (diff) |
Fix registration flow
* 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 <francesco.fiora@est.tech>
Diffstat (limited to 'participant/participant-intermediary/src/main/java')
-rw-r--r-- | participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantRegisterAckListener.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantRegisterAckListener.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantRegisterAckListener.java index 544e66fe4..8b8192e3a 100644 --- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantRegisterAckListener.java +++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantRegisterAckListener.java @@ -45,4 +45,9 @@ public class ParticipantRegisterAckListener extends ParticipantAckListener<Parti public String getType() { return ParticipantMessageType.PARTICIPANT_REGISTER_ACK.name(); } + + @Override + public boolean isDefaultTopic() { + return false; + } } |