[Amdatu-commits] SVN r649 - sandbox/ivol/standalone-cassandra/src/org/amdatu/cassandra

[subvers...@amdatu.org]

Author: ivol37 at gmail.com
Date: Fri Jan 14 15:36:25 2011
New Revision: 649

Log:


Modified:
   sandbox/ivol/standalone-cassandra/src/org/amdatu/cassandra/Main.java

Modified: sandbox/ivol/standalone-cassandra/src/org/amdatu/cassandra/Main.java
==============================================================================
--- sandbox/ivol/standalone-cassandra/src/org/amdatu/cassandra/Main.java        
(original)
+++ sandbox/ivol/standalone-cassandra/src/org/amdatu/cassandra/Main.java        
Fri Jan 14 15:36:25 2011
@@ -9,6 +9,7 @@
 import java.util.ArrayList;
 import java.util.List;
 
+import org.apache.cassandra.config.DatabaseDescriptor;
 import org.apache.cassandra.db.Table;
 import org.apache.cassandra.thrift.Cassandra;
 import org.apache.cassandra.thrift.CassandraDaemon;
@@ -103,7 +104,7 @@
     }
 
     private Cassandra.Client getClient() throws TTransportException {
-        TTransport tr = new TSocket("localhost", 9160);
+        TTransport tr = new 
TSocket(DatabaseDescriptor.getRpcAddress().getHostAddress(), 
DatabaseDescriptor.getRpcPort());
         TProtocol proto = new TBinaryProtocol(tr);
         Cassandra.Client client = new Cassandra.Client(proto);
         tr.open();