From df2d59fe8da87456dc1b1aedded98abcac150a03 Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@pivotal.io>
Date: Fri, 15 Feb 2019 11:28:21 +0100
Subject: [PATCH] DATACASS-628 - Polishing.

Add synchronization to inserts to properly await completion before querying data.
---
 .../cassandra/core/AsyncCassandraTemplateIntegrationTests.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java
index ba16c2443..736f2b783 100644
--- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java
+++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java
@@ -292,7 +292,7 @@ public class AsyncCassandraTemplateIntegrationTests extends AbstractKeyspaceCrea
 		for (int count = 0; count < 100; count++) {
 			User user = new User("heisenberg" + count, "Walter", "White");
 			expectedIds.add(user.getId());
-			template.insert(user);
+			getUninterruptibly(template.insert(user));
 		}
 
 		Set<String> ids = new HashSet<>();