From d5c645873589e0b56a6ad0edd5bd0d480896f765 Mon Sep 17 00:00:00 2001 From: FrancescoFioraEst Date: Tue, 20 Jul 2021 15:49:57 +0100 Subject: Add Retry and Timeout handling Implementaton of Supervision, Retry and Timeout handling on all Participant messages Issue-ID: POLICY-3455 Change-Id: Idfd53ea0b8f5bb1272703256b983a6cbeeb4fdf4 Signed-off-by: FrancescoFioraEst --- .../runtime/instantiation/ControlLoopInstantiationProviderTest.java | 2 +- .../controlloop/runtime/supervision/comm/SupervisionMessagesTest.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'runtime-controlloop/src/test') diff --git a/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/instantiation/ControlLoopInstantiationProviderTest.java b/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/instantiation/ControlLoopInstantiationProviderTest.java index 1c8d17805..c414ffa02 100644 --- a/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/instantiation/ControlLoopInstantiationProviderTest.java +++ b/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/instantiation/ControlLoopInstantiationProviderTest.java @@ -119,7 +119,7 @@ class ControlLoopInstantiationProviderTest { var participantDeregisterAckPublisher = Mockito.mock(ParticipantDeregisterAckPublisher.class); var participantUpdatePublisher = Mockito.mock(ParticipantUpdatePublisher.class); supervisionHandler = new SupervisionHandler(clProvider, participantProvider, monitoringProvider, - commissioningProvider, controlLoopUpdatePublisher, controlLoopStateChangePublisher, + controlLoopUpdatePublisher, controlLoopStateChangePublisher, participantRegisterAckPublisher, participantDeregisterAckPublisher, participantUpdatePublisher); } diff --git a/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/supervision/comm/SupervisionMessagesTest.java b/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/supervision/comm/SupervisionMessagesTest.java index da242d794..5f00706e1 100644 --- a/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/supervision/comm/SupervisionMessagesTest.java +++ b/runtime-controlloop/src/test/java/org/onap/policy/clamp/controlloop/runtime/supervision/comm/SupervisionMessagesTest.java @@ -96,7 +96,7 @@ class SupervisionMessagesTest extends CommonRestController { var participantDeregisterAckPublisher = Mockito.mock(ParticipantDeregisterAckPublisher.class); var participantUpdatePublisher = Mockito.mock(ParticipantUpdatePublisher.class); supervisionHandler = new SupervisionHandler(clProvider, participantProvider, monitoringProvider, - commissioningProvider, controlLoopUpdatePublisher, controlLoopStateChangePublisher, + controlLoopUpdatePublisher, controlLoopStateChangePublisher, participantRegisterAckPublisher, participantDeregisterAckPublisher, participantUpdatePublisher); } @@ -196,7 +196,7 @@ class SupervisionMessagesTest extends CommonRestController { participantUpdateMsg.setParticipantDefinitionUpdateMap(participantDefinitionUpdateMap); synchronized (lockit) { - ParticipantUpdatePublisher clUpdatePublisher = new ParticipantUpdatePublisher(); + ParticipantUpdatePublisher clUpdatePublisher = new ParticipantUpdatePublisher(commissioningProvider); clUpdatePublisher.active(Collections.singletonList(Mockito.mock(TopicSink.class))); clUpdatePublisher.send(participantUpdateMsg); } -- cgit 1.2.3-korg