diff options
author | 2021-08-25 14:00:35 +0000 | |
---|---|---|
committer | 2021-08-25 14:00:35 +0000 | |
commit | 7b433410a35049130b5ec27239c3b00783fe1ff8 (patch) | |
tree | 3de14e08d536cc12995302449caa6c5aea7f7f8d /cps-service/src/main/java/org | |
parent | 90fc8dc16f07d6e039edf1c0a4d6883388cf9004 (diff) | |
parent | 8b935c7f04b76ba8203ff6ccab4790a2c2612ff1 (diff) |
Merge "Add timeout to async test-cases"
Diffstat (limited to 'cps-service/src/main/java/org')
-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 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<Void> processDataUpdatedEvent(final String dataspaceName, final String anchorName) { |