You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/07/15 05:05:27 UTC
svn commit: r964291 -
/cassandra/trunk/test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java
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();