From 56b2759cee1931b3d3fb2da5197e47c32982cd19 Mon Sep 17 00:00:00 2001 From: FrancescoFioraEst Date: Tue, 25 Jun 2024 13:39:45 +0100 Subject: Send ParticipantStatusReq message using sync topic Send ParticipantStatusReq message to all replicas using sync topic. Issue-ID: POLICY-5061 Change-Id: I8a104df38a48efef8a8b4eb61f9a944f7434d0a3 Signed-off-by: FrancescoFioraEst --- .../clamp/acm/participant/intermediary/comm/ParticipantCommTest.java | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'participant/participant-intermediary/src/test/java') diff --git a/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantCommTest.java b/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantCommTest.java index cfc5c6f30..eaf89ec51 100644 --- a/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantCommTest.java +++ b/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/comm/ParticipantCommTest.java @@ -24,6 +24,7 @@ import static org.junit.jupiter.api.Assertions.assertDoesNotThrow; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.assertThrows; +import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.mock; import java.util.Collections; @@ -52,12 +53,14 @@ class ParticipantCommTest { var participantRegisterAckListener = new ParticipantRegisterAckListener(participantHandler); participantRegisterAckListener.onTopicEvent(null, null, null, new ParticipantRegisterAck()); assertEquals(ParticipantMessageType.PARTICIPANT_REGISTER_ACK.name(), participantRegisterAckListener.getType()); + assertFalse(participantRegisterAckListener.isDefaultTopic()); assertEquals(participantRegisterAckListener, participantRegisterAckListener.getScoListener()); var participantStatusReqListener = new ParticipantStatusReqListener(participantHandler); participantStatusReqListener.onTopicEvent(null, null, null, new ParticipantStatusReq()); assertEquals(ParticipantMessageType.PARTICIPANT_STATUS_REQ.name(), participantStatusReqListener.getType()); assertEquals(participantStatusReqListener, participantStatusReqListener.getScoListener()); + assertFalse(participantStatusReqListener.isDefaultTopic()); var participantDeregisterAckListener = new ParticipantDeregisterAckListener(participantHandler); assertEquals(ParticipantMessageType.PARTICIPANT_DEREGISTER_ACK.name(), @@ -65,6 +68,7 @@ class ParticipantCommTest { var participantPrimeListener = new ParticipantPrimeListener(participantHandler); assertEquals(ParticipantMessageType.PARTICIPANT_PRIME.name(), participantPrimeListener.getType()); + assertTrue(participantPrimeListener.isDefaultTopic()); var acPropertyUpdateListener = new AcPropertyUpdateListener(participantHandler); assertEquals(ParticipantMessageType.PROPERTIES_UPDATE.name(), acPropertyUpdateListener.getType()); @@ -80,6 +84,7 @@ class ParticipantCommTest { var participantSyncListener = new ParticipantSyncListener(participantHandler); assertEquals(ParticipantMessageType.PARTICIPANT_SYNC_MSG.name(), participantSyncListener.getType()); + assertFalse(participantSyncListener.isDefaultTopic()); var acMigrationListener = new AutomationCompositionMigrationListener(participantHandler); assertEquals(ParticipantMessageType.AUTOMATION_COMPOSITION_MIGRATION.name(), acMigrationListener.getType()); -- cgit