svn commit: r964291 - /cassandra/trunk/test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java

[jbellis]

Author: jbellis
Date: Thu Jul 15 03:05:11 2010
New Revision: 964291

URL: http://svn.apache.org/viewvc?rev=964291&view=rev
Log:
update EmbeddedCassandraServiceTest client to use framed mode.  patch by jbellis

Modified:
    
cassandra/trunk/test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java

Modified: 
cassandra/trunk/test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java?rev=964291&r1=964290&r2=964291&view=diff
==============================================================================
--- 
cassandra/trunk/test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java
 (original)
+++ 
cassandra/trunk/test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java
 Thu Jul 15 03:05:11 2010
@@ -45,6 +45,7 @@ import org.apache.cassandra.thrift.Unava
 import org.apache.thrift.TException;
 import org.apache.thrift.protocol.TBinaryProtocol;
 import org.apache.thrift.protocol.TProtocol;
+import org.apache.thrift.transport.TFramedTransport;
 import org.apache.thrift.transport.TSocket;
 import org.apache.thrift.transport.TTransport;
 import org.apache.thrift.transport.TTransportException;
@@ -134,7 +135,7 @@ public class EmbeddedCassandraServiceTes
      */
     private Cassandra.Client getClient() throws TTransportException
     {
-        TTransport tr = new TSocket("localhost", 
DatabaseDescriptor.getRpcPort());
+        TTransport tr = new TFramedTransport(new TSocket("localhost", 
DatabaseDescriptor.getRpcPort()));
         TProtocol proto = new TBinaryProtocol(tr);
         Cassandra.Client client = new Cassandra.Client(proto);
         tr.open();