From 9cb9bb9ede6e1607f9d3614d2c36b2800ad323fd Mon Sep 17 00:00:00 2001 From: mikereiche Date: Mon, 15 Jun 2020 13:09:44 -0700 Subject: [PATCH] DATACOUCH-484 - thread safety parameters test --- .../CouchbaseRepositoryQueryIntegrationTests.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/test/java/org/springframework/data/couchbase/repository/CouchbaseRepositoryQueryIntegrationTests.java b/src/test/java/org/springframework/data/couchbase/repository/CouchbaseRepositoryQueryIntegrationTests.java index 3575a72c..1e97c195 100644 --- a/src/test/java/org/springframework/data/couchbase/repository/CouchbaseRepositoryQueryIntegrationTests.java +++ b/src/test/java/org/springframework/data/couchbase/repository/CouchbaseRepositoryQueryIntegrationTests.java @@ -43,6 +43,12 @@ import org.springframework.test.context.junit.jupiter.SpringJUnitConfig; import com.couchbase.client.core.error.IndexExistsException; +/** + * Repository tests + * + * @author Michael Nitschinger + * @author Michael Reiche + */ @SpringJUnitConfig(CouchbaseRepositoryQueryIntegrationTests.Config.class) @IgnoreWhen(missesCapabilities = Capabilities.QUERY, clusterTypes = ClusterType.MOCKED) public class CouchbaseRepositoryQueryIntegrationTests extends ClusterAwareIntegrationTests { @@ -113,6 +119,7 @@ public class CouchbaseRepositoryQueryIntegrationTests extends ClusterAwareIntegr } catch (Exception e) { throw new RuntimeException(e); } finally { + executorService.shutdown(); for (int i = 0; i < iatas.length; i++) { Airport airport = new Airport("airports::" + iatas[i], iatas[i] /*iata*/, iatas[i] /* lcao */); airportRepository.delete(airport); @@ -154,6 +161,7 @@ public class CouchbaseRepositoryQueryIntegrationTests extends ClusterAwareIntegr } catch (Exception e) { throw new RuntimeException(e); } finally { + executorService.shutdown(); for (int i = 0; i < iatas.length; i++) { Airport airport = new Airport("airports::" + iatas[i], iatas[i] /*iata*/, iatas[i] /* lcao */); airportRepository.delete(airport);