Added C* port to config

Author: larsp

lack/src/main/java/io/datanerds/lack/cassandra/CassandraClient.java

@@ -13,7 +13,7 @@ public class CassandraClient {
     private Cluster cluster;
 
     public Session init(LackConfig config) {
-        Cluster.Builder clusterBuilder = new Cluster.Builder().addContactPoints(config.nodes)
+        Cluster.Builder clusterBuilder = new Cluster.Builder().addContactPoints(config.nodes).withPort(config.port)
                 .withSocketOptions(new SocketOptions().setTcpNoDelay(true).setReuseAddress(true));
         if (config.username != null && config.password != null) {
             clusterBuilder.withCredentials(config.username, config.password);

lack/src/main/java/io/datanerds/lack/cassandra/LackConfig.java

@@ -7,6 +7,7 @@ public class LackConfig {
     public final String[] nodes;
     public final String keyspace;
     public final int ttlInSeconds;
+    public int port = 9142;
 
     public LackConfig(String username, String password, String[] nodes, String keyspace, int ttlInSeconds) {
         this.username = username;
@@ -15,4 +16,13 @@ public LackConfig(String username, String password, String[] nodes, String keysp
         this.keyspace = keyspace;
         this.ttlInSeconds = ttlInSeconds;
     }
+
+    public LackConfig(String username, String password, String[] nodes, int port, String keyspace, int ttlInSeconds) {
+        this.username = username;
+        this.password = password;
+        this.nodes = nodes;
+        this.keyspace = keyspace;
+        this.ttlInSeconds = ttlInSeconds;
+        this.port = port;
+    }
 }