Skip to content
Snippets Groups Projects
Commit 9e913b79 authored by sainthxd@gmail.com's avatar sainthxd@gmail.com
Browse files

change the port of Cassandra (previous version 1.2) as a parameter instead of a constant 9160

parent 35720bb2
No related branches found
No related tags found
No related merge requests found
......@@ -136,7 +136,7 @@ public class CassandraClient10 extends DB
for (int retry = 0; retry < ConnectionRetries; retry++)
{
tr = new TFramedTransport(new TSocket(myhost, 9160));
tr = new TFramedTransport(new TSocket(myhost, Integer.parseInt(getProperties().getProperty("port","9160"))));
TProtocol proto = new TBinaryProtocol(tr);
client = new Cassandra.Client(proto);
try
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment