Skip to content
Snippets Groups Projects
Commit 6a0d00d7 authored by Sean Busbey's avatar Sean Busbey
Browse files

Merge pull request #360 from jixuan1989/track_official_new

[cassandra] change the port of Cassandra (previous version 1.2) as a parameter instead of a constant value such as 9160
parents 35720bb2 9e913b79
No related branches found
No related tags found
No related merge requests found
...@@ -136,7 +136,7 @@ public class CassandraClient10 extends DB ...@@ -136,7 +136,7 @@ public class CassandraClient10 extends DB
for (int retry = 0; retry < ConnectionRetries; retry++) 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); TProtocol proto = new TBinaryProtocol(tr);
client = new Cassandra.Client(proto); client = new Cassandra.Client(proto);
try 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