From 2cfcc6756e59ed8cda571efa8b29764eab7837c8 Mon Sep 17 00:00:00 2001 From: wasala Date: Fri, 22 Jun 2018 20:11:20 +0200 Subject: Added reactive tasks flow control Change-Id: I9cb2bede66e9e446912f2e6a815c7b56b80813b9 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala --- .../java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskSpy.java | 2 +- .../java/org/onap/dcaegen2/services/prh/tasks/DmaapProducerTaskSpy.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'prh-app-server/src/test') diff --git a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskSpy.java b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskSpy.java index 60e1bd54..5736afeb 100644 --- a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskSpy.java +++ b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskSpy.java @@ -41,7 +41,7 @@ public class DmaapConsumerTaskSpy { @Bean @Primary - public Task registerSimpleDmaapConsumerTask() { + public DmaapConsumerTask registerSimpleDmaapConsumerTask() { AppConfig appConfig = spy(AppConfig.class); doReturn(mock(DmaapConsumerConfiguration.class)).when(appConfig).getDmaapConsumerConfiguration(); DmaapConsumerTaskImpl dmaapConsumerTask = spy(new DmaapConsumerTaskImpl(appConfig)); diff --git a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapProducerTaskSpy.java b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapProducerTaskSpy.java index b2b97cf0..01056606 100644 --- a/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapProducerTaskSpy.java +++ b/prh-app-server/src/test/java/org/onap/dcaegen2/services/prh/tasks/DmaapProducerTaskSpy.java @@ -39,7 +39,7 @@ public class DmaapProducerTaskSpy { @Bean @Primary - public Task registerSimpleDmaapPublisherTask() { + public DmaapPublisherTask registerSimpleDmaapPublisherTask() { AppConfig appConfig = spy(AppConfig.class); doReturn(mock(DmaapPublisherConfiguration.class)).when(appConfig).getDmaapPublisherConfiguration(); DmaapPublisherTaskImpl dmaapPublisherTask = spy(new DmaapPublisherTaskImpl(appConfig)); -- cgit 1.2.3-korg