diff options
Diffstat (limited to 'runtime-acm/src/test/java')
2 files changed, 6 insertions, 4 deletions
diff --git a/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java b/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java index bebaa3319..932529d79 100644 --- a/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java +++ b/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/SupervisionParticipantHandlerTest.java @@ -104,7 +104,7 @@ class SupervisionParticipantHandlerTest { verify(participantProvider).saveParticipant(any()); verify(participantRegisterAckPublisher).send(participantRegisterMessage.getMessageId(), - CommonTestData.getParticipantId()); + CommonTestData.getParticipantId(), null); } @Test @@ -158,7 +158,8 @@ class SupervisionParticipantHandlerTest { CommonTestData.getTestParamaterGroup()); handler.handleParticipantMessage(participantRegisterMessage); - verify(participantRegisterAckPublisher).send(participantRegisterMessage.getMessageId(), participantId); + verify(participantRegisterAckPublisher) + .send(participantRegisterMessage.getMessageId(), participantId, participantId); verify(acDefinitionProvider).updateAcDefinition(any(AutomationCompositionDefinition.class), eq(CommonTestData.TOSCA_COMP_NAME)); verify(participantRestartPublisher).send(any(), any(AutomationCompositionDefinition.class), any()); @@ -216,7 +217,8 @@ class SupervisionParticipantHandlerTest { CommonTestData.getTestParamaterGroup()); handler.handleParticipantMessage(participantRegisterMessage); - verify(participantRegisterAckPublisher).send(participantRegisterMessage.getMessageId(), participantId); + verify(participantRegisterAckPublisher) + .send(participantRegisterMessage.getMessageId(), participantId, replicaId); verify(acDefinitionProvider, times(0)).updateAcDefinition(any(AutomationCompositionDefinition.class), eq(CommonTestData.TOSCA_COMP_NAME)); verify(participantSyncPublisher) diff --git a/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/comm/SupervisionMessagesTest.java b/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/comm/SupervisionMessagesTest.java index cab5adf9c..7cf0bf84f 100644 --- a/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/comm/SupervisionMessagesTest.java +++ b/runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/supervision/comm/SupervisionMessagesTest.java @@ -200,7 +200,7 @@ class SupervisionMessagesTest { var publisher = new ParticipantRegisterAckPublisher(); var topicSink = mock(TopicSink.class); publisher.active(topicSink); - publisher.send(UUID.randomUUID(), CommonTestData.getParticipantId()); + publisher.send(UUID.randomUUID(), CommonTestData.getParticipantId(), CommonTestData.getReplicaId()); verify(topicSink).send(anyString()); } |