svn commit: r980285 - in /cassandra/trunk: src/java/org/apache/cassandra/cli/CliMain.java src/java/org/apache/cassandra/client/RingCache.java test/unit/org/apache/cassandra/client/TestRingCache.java

[jbellis]

Author: jbellis
Date: Thu Jul 29 01:47:26 2010
New Revision: 980285

URL: http://svn.apache.org/viewvc?rev=980285&view=rev
Log:
update to use modern TBinaryProtocol everywhere.  patch by jbellis

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/cli/CliMain.java
    cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java
    cassandra/trunk/test/unit/org/apache/cassandra/client/TestRingCache.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/cli/CliMain.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/cli/CliMain.java?rev=980285&r1=980284&r2=980285&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/cli/CliMain.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/cli/CliMain.java Thu Jul 29 
01:47:26 2010
@@ -80,7 +80,7 @@ public class CliMain
             transport_ = socket;
         }
 
-        TBinaryProtocol binaryProtocol = new TBinaryProtocol(transport_, 
false, false);
+        TBinaryProtocol binaryProtocol = new TBinaryProtocol(transport_);
         Cassandra.Client cassandraClient = new 
Cassandra.Client(binaryProtocol);
 
         try

Modified: cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java?rev=980285&r1=980284&r2=980285&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java 
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java Thu Jul 
29 01:47:26 2010
@@ -76,7 +76,7 @@ public class RingCache
             try
             {
                 TSocket socket = new TSocket(seed, port_);
-                TBinaryProtocol binaryProtocol = new TBinaryProtocol(socket, 
false, false);
+                TBinaryProtocol binaryProtocol = new TBinaryProtocol(socket);
                 Cassandra.Client client = new Cassandra.Client(binaryProtocol);
                 socket.open();
 

Modified: 
cassandra/trunk/test/unit/org/apache/cassandra/client/TestRingCache.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/test/unit/org/apache/cassandra/client/TestRingCache.java?rev=980285&r1=980284&r2=980285&view=diff
==============================================================================
--- cassandra/trunk/test/unit/org/apache/cassandra/client/TestRingCache.java 
(original)
+++ cassandra/trunk/test/unit/org/apache/cassandra/client/TestRingCache.java 
Thu Jul 29 01:47:26 2010
@@ -56,7 +56,7 @@ public class TestRingCache
         TTransport transport;
         System.out.println(" connected to " + server + ":" + port + ".");
         transport = socket;
-        TBinaryProtocol binaryProtocol = new TBinaryProtocol(transport, false, 
false);
+        TBinaryProtocol binaryProtocol = new TBinaryProtocol(transport);
         Cassandra.Client cassandraClient = new 
Cassandra.Client(binaryProtocol);
         transport.open();
         thriftClient = cassandraClient;