diff options
Diffstat (limited to 'participant/participant-impl/participant-impl-policy')
| -rw-r--r-- | participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/controlloop/participant/policy/endtoend/ParticipantMessagesTest.java | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/controlloop/participant/policy/endtoend/ParticipantMessagesTest.java b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/controlloop/participant/policy/endtoend/ParticipantMessagesTest.java index 699df25e8..8187378ae 100644 --- a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/controlloop/participant/policy/endtoend/ParticipantMessagesTest.java +++ b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/controlloop/participant/policy/endtoend/ParticipantMessagesTest.java @@ -85,7 +85,8 @@ class ParticipantMessagesTest { synchronized (lockit) { ParticipantMessagePublisher participantMessagePublisher = - new ParticipantMessagePublisher(Collections.singletonList(Mockito.mock(TopicSink.class))); + new ParticipantMessagePublisher(); + participantMessagePublisher.active(Collections.singletonList(Mockito.mock(TopicSink.class))); participantMessagePublisher.sendParticipantRegister(participantRegisterMsg); } } @@ -113,7 +114,8 @@ class ParticipantMessagesTest { synchronized (lockit) { ParticipantMessagePublisher participantMessagePublisher = - new ParticipantMessagePublisher(Collections.singletonList(Mockito.mock(TopicSink.class))); + new ParticipantMessagePublisher(); + participantMessagePublisher.active(Collections.singletonList(Mockito.mock(TopicSink.class))); participantMessagePublisher.sendParticipantDeregister(participantDeregisterMsg); } } @@ -153,8 +155,8 @@ class ParticipantMessagesTest { participantUpdateAckMsg.setResult(true); synchronized (lockit) { - ParticipantMessagePublisher participantMessagePublisher = - new ParticipantMessagePublisher(Collections.singletonList(Mockito.mock(TopicSink.class))); + ParticipantMessagePublisher participantMessagePublisher = new ParticipantMessagePublisher(); + participantMessagePublisher.active(Collections.singletonList(Mockito.mock(TopicSink.class))); participantMessagePublisher.sendParticipantUpdateAck(participantUpdateAckMsg); } } @@ -163,8 +165,8 @@ class ParticipantMessagesTest { void testParticipantStatusHeartbeat() throws Exception { final ParticipantStatus heartbeat = participantHandler.makeHeartbeat(true); synchronized (lockit) { - ParticipantMessagePublisher publisher = - new ParticipantMessagePublisher(Collections.singletonList(Mockito.mock(TopicSink.class))); + ParticipantMessagePublisher publisher = new ParticipantMessagePublisher(); + publisher.active(Collections.singletonList(Mockito.mock(TopicSink.class))); assertThatCode(() -> publisher.sendHeartbeat(heartbeat)).doesNotThrowAnyException(); } } |