diff options
Diffstat (limited to 'integration-test/src')
2 files changed, 13 insertions, 0 deletions
diff --git a/integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy b/integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy index 9fc36331e2..16b4460492 100644 --- a/integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy +++ b/integration-test/src/test/groovy/org/onap/cps/integration/base/CpsIntegrationSpecBase.groovy @@ -22,6 +22,7 @@ package org.onap.cps.integration.base import com.hazelcast.collection.ISet +import com.hazelcast.map.IMap import okhttp3.mockwebserver.MockWebServer import org.onap.cps.api.CpsAnchorService import org.onap.cps.api.CpsDataService @@ -123,6 +124,9 @@ abstract class CpsIntegrationSpecBase extends Specification { BlockingQueue<String> moduleSyncWorkQueue @Autowired + IMap<String, String> cpsAndNcmpLock + + @Autowired JsonObjectMapper jsonObjectMapper @Autowired diff --git a/integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/ModuleSyncWatchdogIntegrationSpec.groovy b/integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/ModuleSyncWatchdogIntegrationSpec.groovy index 43bcbdb4f4..a6e56ab22d 100644 --- a/integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/ModuleSyncWatchdogIntegrationSpec.groovy +++ b/integration-test/src/test/groovy/org/onap/cps/integration/functional/ncmp/ModuleSyncWatchdogIntegrationSpec.groovy @@ -151,6 +151,15 @@ class ModuleSyncWatchdogIntegrationSpec extends CpsIntegrationSpecBase { } } + def populateQueueWithoutDelayCallable = () -> { + try { + objectUnderTest.populateWorkQueueIfNeeded() + return 'task acquired the lock first' + } catch (InterruptedException e) { + e.printStackTrace() + } + } + def populateQueueWithDelay = () -> { try { Thread.sleep(10) |