fix(cassandra) allow overriding consistency level

Fix Kong#1314
dhavirb · Jul 5, 2016 · 585fb17 · 585fb17
1 parent bd00edf
commit 585fb17
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/kong/dao/cassandra_db.lua b/kong/dao/cassandra_db.lua
@@ -30,7 +30,12 @@ function CassandraDB:new(options)
       default_port = options.port
     },
     query_options = {
-      prepare = true
+      prepare = true,
+      consistency = cassandra.consistencies[options.consistency:lower()]
+    },
+    socket_options = {
+      connect_timeout = options.timeout,
+      read_timeout = options.timeout
     },
     ssl_options = {
       enabled = options.ssl.enabled,