summaryrefslogtreecommitdiffstats
path: root/cps-service/src/test/groovy/org
diff options
context:
space:
mode:
authorBruno Sakoto <bruno.sakoto@bell.ca>2021-08-25 14:00:35 +0000
committerGerrit Code Review <gerrit@onap.org>2021-08-25 14:00:35 +0000
commit7b433410a35049130b5ec27239c3b00783fe1ff8 (patch)
tree3de14e08d536cc12995302449caa6c5aea7f7f8d /cps-service/src/test/groovy/org
parent90fc8dc16f07d6e039edf1c0a4d6883388cf9004 (diff)
parent8b935c7f04b76ba8203ff6ccab4790a2c2612ff1 (diff)
Merge "Add timeout to async test-cases"
Diffstat (limited to 'cps-service/src/test/groovy/org')
-rw-r--r--cps-service/src/test/groovy/org/onap/cps/notification/NotificationServiceSpec.groovy18
1 files changed, 12 insertions, 6 deletions
diff --git a/cps-service/src/test/groovy/org/onap/cps/notification/NotificationServiceSpec.groovy b/cps-service/src/test/groovy/org/onap/cps/notification/NotificationServiceSpec.groovy
index 0a2d3d9988..ab727671e1 100644
--- a/cps-service/src/test/groovy/org/onap/cps/notification/NotificationServiceSpec.groovy
+++ b/cps-service/src/test/groovy/org/onap/cps/notification/NotificationServiceSpec.groovy
@@ -32,6 +32,8 @@ import org.springframework.test.context.ContextConfiguration
import spock.lang.Shared
import spock.lang.Specification
+import java.util.concurrent.TimeUnit
+
@SpringBootTest
@EnableAsync
@EnableConfigurationProperties
@@ -71,9 +73,11 @@ class NotificationServiceSpec extends Specification {
mockCpsDataUpdatedEventFactory.createCpsDataUpdatedEvent(dataspaceName, myAnchorName) >> cpsDataUpdatedEvent
when: 'dataUpdatedEvent is received'
def future = objectUnderTest.processDataUpdatedEvent(dataspaceName, myAnchorName)
- and: 'async processing is completed'
- future.get()
- then: 'notification is sent'
+ and: 'wait for async processing is completed'
+ future.get(10, TimeUnit.SECONDS)
+ then: 'async process completed successfully'
+ future.isDone()
+ and: 'notification is sent'
expectedSendNotificationCount * mockNotificationPublisher.sendNotification(cpsDataUpdatedEvent)
where:
scenario | dataspaceName || expectedSendNotificationCount
@@ -89,9 +93,11 @@ class NotificationServiceSpec extends Specification {
{ throw new Exception("Could not create event") }
when: 'event is sent for processing'
def future = objectUnderTest.processDataUpdatedEvent(myDataspacePublishedName, myAnchorName)
- and: 'async processing is completed'
- future.get()
- then: 'error is handled and not thrown to caller'
+ and: 'wait for async processing is completed'
+ future.get(10, TimeUnit.SECONDS)
+ then: 'async process completed successfully'
+ future.isDone()
+ and: 'error is handled and not thrown to caller'
notThrown Exception
1 * spyNotificationErrorHandler.onException(_, _, _, _)
}