Spring/spring-data-couchbase
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACOUCH-484 - thread safety parameters test

Browse Source
This commit is contained in:
mikereiche
2020-06-15 13:09:44 -07:00
parent c3fbf38ba2
commit 9cb9bb9ede
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/org/springframework/data/couchbase/repository/CouchbaseRepositoryQueryIntegrationTests.java
View File

@@ -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);