svn commit: r983231 - /cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java

[jbellis]

Author: jbellis
Date: Sat Aug  7 14:17:37 2010
New Revision: 983231

URL: http://svn.apache.org/viewvc?rev=983231&view=rev
Log:
Used FramedTransport in RingCache
patch by Stu Hood; reviewed by jbellis for CASSANDRA-1322

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java

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=983231&r1=983230&r2=983231&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java 
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/client/RingCache.java Sat Aug 
 7 14:17:37 2010
@@ -37,6 +37,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.apache.thrift.TException;
 import org.apache.thrift.protocol.TBinaryProtocol;
+import org.apache.thrift.transport.TFramedTransport;
 import org.apache.thrift.transport.TSocket;
 
 import com.google.common.collect.BiMap;
@@ -76,7 +77,7 @@ public class RingCache
             try
             {
                 TSocket socket = new TSocket(seed, port_);
-                TBinaryProtocol binaryProtocol = new TBinaryProtocol(socket);
+                TBinaryProtocol binaryProtocol = new TBinaryProtocol(new 
TFramedTransport(socket));
                 Cassandra.Client client = new Cassandra.Client(binaryProtocol);
                 socket.open();