From 8b935c7f04b76ba8203ff6ccab4790a2c2612ff1 Mon Sep 17 00:00:00 2001 From: Renu Kumari Date: Wed, 25 Aug 2021 09:32:35 -0400 Subject: Add timeout to async test-cases Issue-ID: CPS-526 Signed-off-by: Renu Kumari Change-Id: Icf46f94090a615bf945eb70b58edf86c0c509155 --- cps-service/src/main/java/org/onap/cps/config/AsyncConfig.java | 2 +- .../src/main/java/org/onap/cps/notification/NotificationService.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) (limited to 'cps-service/src/main/java/org/onap') diff --git a/cps-service/src/main/java/org/onap/cps/config/AsyncConfig.java b/cps-service/src/main/java/org/onap/cps/config/AsyncConfig.java index 3ae675e21..4c961598e 100644 --- a/cps-service/src/main/java/org/onap/cps/config/AsyncConfig.java +++ b/cps-service/src/main/java/org/onap/cps/config/AsyncConfig.java @@ -42,7 +42,7 @@ public class AsyncConfig { @Min(2) private int maxPoolSize = 10; @Min(0) - private int queueCapacity = 2147483647; + private int queueCapacity = Integer.MAX_VALUE; private boolean waitForTasksToCompleteOnShutdown = true; private String threadNamePrefix = "Async-"; diff --git a/cps-service/src/main/java/org/onap/cps/notification/NotificationService.java b/cps-service/src/main/java/org/onap/cps/notification/NotificationService.java index 9ed8b65ad..4745739a4 100644 --- a/cps-service/src/main/java/org/onap/cps/notification/NotificationService.java +++ b/cps-service/src/main/java/org/onap/cps/notification/NotificationService.java @@ -79,6 +79,7 @@ public class NotificationService { * * @param dataspaceName dataspace name * @param anchorName anchor name + * @return future */ @Async("notificationExecutor") public Future processDataUpdatedEvent(final String dataspaceName, final String anchorName) { -- cgit 1.2.3-korg