Permalink
Browse files

Used FramedTransport in RingCache

patch by Stu Hood; reviewed by jbellis for CASSANDRA-1322


git-svn-id: https://svn.apache.org/repos/asf/cassandra/trunk@983231 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information...
jbellis committed Aug 7, 2010
1 parent 8b9beaa commit fce7c1551c352d9c207a0a852176030a41a89935
Showing with 2 additions and 1 deletion.
  1. +2 −1 src/java/org/apache/cassandra/client/RingCache.java
@@ -37,6 +37,7 @@
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 void refreshEndpointMap()
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();

0 comments on commit fce7c15

Please sign in to comment.