diff options
| author |   Renu Kumari <renu.kumari@bell.ca> | 2021-08-25 09:32:35 -0400 |
|---|---|---|
| committer | Renu Kumari <renu.kumari@bell.ca> | 2021-08-25 09:32:35 -0400 |
| commit | 8b935c7f04b76ba8203ff6ccab4790a2c2612ff1 (patch) | |
| tree | 34fafca2854471059cb3ba45b0f7adf4d30b0035 /cps-service/src/main/java | |
| parent | 86c74c79cb45992d9f2ec134477cae41cd26651b (diff) | |
Add timeout to async test-cases
Issue-ID: CPS-526
Signed-off-by: Renu Kumari <renu.kumari@bell.ca>
Change-Id: Icf46f94090a615bf945eb70b58edf86c0c509155
Diffstat (limited to 'cps-service/src/main/java')
| -rw-r--r-- | cps-service/src/main/java/org/onap/cps/config/AsyncConfig.java | 2 | ||||
| -rw-r--r-- | cps-service/src/main/java/org/onap/cps/notification/NotificationService.java | 1 |
2 files changed, 2 insertions, 1 deletions
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 3ae675e214..4c961598e4 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 9ed8b65ad7..4745739a4f 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<Void> processDataUpdatedEvent(final String dataspaceName, final String anchorName) { |