DATACASS-628 - Polishing.
Add synchronization to inserts to properly await completion before querying data.
This commit is contained in:
@@ -317,7 +317,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<>();
|
||||
|
||||
Reference in New Issue
Block a user