Quorum consistency (#2)

* Set default consistency level to QUORUM

Author: markglh

src/main/scala/de/kaufhof/pillar/Migration.scala

@@ -77,4 +77,4 @@ class ReversibleMigration(val description: String, val authoredAt: Date, val up:
     session.execute(down)
     deleteFromAppliedMigrations(session)
   }
-}
+}

src/main/scala/de/kaufhof/pillar/cli/App.scala

@@ -2,7 +2,7 @@ package de.kaufhof.pillar.cli
 
 import java.io.File
 
-import com.datastax.driver.core.Cluster
+import com.datastax.driver.core.{ConsistencyLevel, QueryOptions, Cluster}
 import com.typesafe.config.{Config, ConfigFactory}
 import de.kaufhof.pillar._
 import de.kaufhof.pillar.config.ConnectionConfiguration
@@ -64,10 +64,14 @@ class App(reporter: Reporter, configuration: Config) {
     }
   }
 
-  private def createCluster(connectionConfiguration: ConnectionConfiguration): Cluster = {
+  private def createCluster(connectionConfiguration:ConnectionConfiguration): Cluster = {
+    val queryOptions = new QueryOptions()
+    queryOptions.setConsistencyLevel(ConsistencyLevel.QUORUM)
+
     val clusterBuilder = Cluster.builder()
       .addContactPoint(connectionConfiguration.seedAddress)
       .withPort(connectionConfiguration.port)
+      .withQueryOptions(queryOptions)
     connectionConfiguration.auth.foreach(clusterBuilder.withAuthProvider)
 
     connectionConfiguration.sslConfig.foreach(_.setAsSystemProperties())