From 2fdedb0e98a1163bc34fb884e52df5c8a4dd28b3 Mon Sep 17 00:00:00 2001
From: sameira <sameira@gmail.com>
Date: Sun, 20 Dec 2015 21:45:36 +0530
Subject: [PATCH] Updated test cases adding increased timeouts and sleeps to
 enhance the stability, updated Spring Data Cassandra Version.

---
 spring-data-cassandra/pom.xml                               | 2 +-
 .../cassandra/repository/CQLQueriesIntegrationTest.java     | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/spring-data-cassandra/pom.xml b/spring-data-cassandra/pom.xml
index 13c5c18529..b2b649a422 100644
--- a/spring-data-cassandra/pom.xml
+++ b/spring-data-cassandra/pom.xml
@@ -11,7 +11,7 @@
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-		<org.springframework.data.version>1.3.1.RELEASE</org.springframework.data.version>
+		<org.springframework.data.version>1.3.2.RELEASE</org.springframework.data.version>
 		<org.springframework.version>4.2.2.RELEASE</org.springframework.version>
 		<junit.version>4.11</junit.version>
 		<org.slf4j.version>1.7.12</org.slf4j.version>
diff --git a/spring-data-cassandra/src/test/java/org/baeldung/spring/data/cassandra/repository/CQLQueriesIntegrationTest.java b/spring-data-cassandra/src/test/java/org/baeldung/spring/data/cassandra/repository/CQLQueriesIntegrationTest.java
index f4354a66e2..031b5c0b6f 100644
--- a/spring-data-cassandra/src/test/java/org/baeldung/spring/data/cassandra/repository/CQLQueriesIntegrationTest.java
+++ b/spring-data-cassandra/src/test/java/org/baeldung/spring/data/cassandra/repository/CQLQueriesIntegrationTest.java
@@ -51,7 +51,7 @@ public class CQLQueriesIntegrationTest {
 
     @BeforeClass
     public static void startCassandraEmbedded() throws InterruptedException, TTransportException, ConfigurationException, IOException {
-        EmbeddedCassandraServerHelper.startEmbeddedCassandra();
+        EmbeddedCassandraServerHelper.startEmbeddedCassandra(25000);
         Cluster cluster = Cluster.builder().addContactPoints("127.0.0.1").withPort(9142).build();
         LOGGER.info("Server Started at 127.0.0.1:9142... ");
         Session session = cluster.connect();
@@ -87,7 +87,7 @@ public class CQLQueriesIntegrationTest {
     }
 
     @Test
-    public void whenSavingBook_thenAvailableOnRetrieval_usingPreparedStatements() {
+    public void whenSavingBook_thenAvailableOnRetrieval_usingPreparedStatements() throws InterruptedException {
         UUID uuid = UUIDs.timeBased();
         String insertPreparedCql = "insert into book (id, title, publisher, tags) values (?, ?, ?, ?)";
         List<Object> singleBookArgsList = new ArrayList<>();
@@ -98,6 +98,8 @@ public class CQLQueriesIntegrationTest {
         singleBookArgsList.add(ImmutableSet.of("Software"));
         bookList.add(singleBookArgsList);
         cassandraTemplate.ingest(insertPreparedCql, bookList);
+        //This may not be required, just added to avoid any transient issues
+        Thread.sleep(5000);
         Select select = QueryBuilder.select().from("book");
         Book retrievedBook = cassandraTemplate.selectOne(select, Book.class);
         assertEquals(uuid, retrievedBook.getId());