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

[subvers...@amdatu.org]

Author: ivol37 at gmail.com
Date: Fri Jan 14 15:37:23 2011
New Revision: 650

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:37:23 2011
@@ -104,6 +104,7 @@
     }
 
     private Cassandra.Client getClient() throws TTransportException {
+        System.out.println("Connecting Thrift to " + 
DatabaseDescriptor.getRpcAddress().getHostAddress() + ":" + 
DatabaseDescriptor.getRpcPort());
         TTransport tr = new 
TSocket(DatabaseDescriptor.getRpcAddress().getHostAddress(), 
DatabaseDescriptor.getRpcPort());
         TProtocol proto = new TBinaryProtocol(tr);
         Cassandra.Client client = new Cassandra.Client(proto);