Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (athena.apache.org: domain of edlinuxguru@gmail.com
 designates 209.85.161.44 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=w33BshfEtkaK1OSMtVakry5jQaZZ3hafJ/PZWI2JKcWkZyUSI8Mn3MO8MG6p8C1YGx
         wRoZPAE4fi37hof1hHt0qUE62the2mZf13tpqdTCPTSRvrpTSZkLlz3xVt8QIaraYNyJ
         KQd4pW942sgA4u1iqdhYinz/ap2PkK5xxFZzw=
MIME-Version: 1.0
In-Reply-To: <AANLkTimHrXZe0rFqzW34+VS_oQKxjY9HibyvavTk0ONy@mail.gmail.com>
References: <AANLkTinZJGyGyGTkSrSZB+LUbd4evtp1FHpD5c+tFg5C@mail.gmail.com>
	<AANLkTikFLRLWH5HH3O58FBuU95w1X6f2kuUBi4Le2o-L@mail.gmail.com>
	<AANLkTimHrXZe0rFqzW34+VS_oQKxjY9HibyvavTk0ONy@mail.gmail.com>
Date: Sat, 6 Nov 2010 11:41:45 -0400
Message-ID: <AANLkTik4=ZsSYkznxNVK+P0Jf5r5rEnG0qZnX1kTqQrz@mail.gmail.com>
Subject: Re: client connecting to 0.7
From: Edward Capriolo <edlinuxguru@gmail.com>
To: user@cassandra.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Fri, Nov 5, 2010 at 9:50 PM, CassUser CassUser <cassuser@gmail.com> wrot=
e:
> I agree and we will move to hector=A0 at some point, but we have some leg=
acy
> code we need to convert to the new api.=A0 What am I doing wrong in the c=
ode I
> posted?
>
>
> On Fri, Nov 5, 2010 at 5:45 PM, Jonathan Ellis <jbellis@gmail.com> wrote:
>>
>> From Java you should be using Hector instead of messing around with
>> raw Thrift. =A0There is a version for beta2 at
>> https://github.com/rantav/hector/downloads
>>
>> docs are at
>> http://www.riptano.com/sites/default/files/hector-v2-client-doc.pdf
>>
>> On Fri, Nov 5, 2010 at 6:28 PM, CassUser CassUser <cassuser@gmail.com>
>> wrote:
>> > Hey I'm testing a client on beta2 cassandra version 0.7.
>> >
>> > =A0=A0=A0=A0=A0=A0=A0 TFramedTransport transport =3D new TFramedTransp=
ort(new
>> > TSocket("my.ip", 9160));
>> > =A0=A0=A0=A0=A0=A0=A0 Cassandra.Client client =3D new Cassandra.Client=
(new
>> > TBinaryProtocol(transport));
>> > =A0=A0=A0=A0=A0=A0=A0 transport.open();
>> > =A0=A0=A0=A0=A0=A0=A0 System.out.println(client.describe_cluster_name(=
));
>> >
>> > Is giving me the following:
>> >
>> > org.apache.thrift.protocol.TProtocolException: Missing version in
>> > readMessageBegin, old client?
>> > =A0=A0=A0=A0=A0=A0=A0 at
>> >
>> > org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryPro=
tocol.java:211)
>> > =A0=A0=A0=A0=A0=A0=A0 at
>> >
>> > org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java=
:2706)
>> > =A0=A0=A0=A0=A0=A0=A0 at
>> >
>> > org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(=
CustomTThreadPoolServer.java:167)
>> > =A0=A0=A0=A0=A0=A0=A0 at
>> >
>> > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecu=
tor.java:886)
>> > =A0=A0=A0=A0=A0=A0=A0 at
>> >
>> > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.=
java:908)
>> > =A0=A0=A0=A0=A0=A0=A0 at java.lang.Thread.run(Thread.java:662)
>> >
>> > I'm using the cassandra 0.7beta2 code on both client and server.
>> >
>>
>>
>>
>> --
>> Jonathan Ellis
>> Project Chair, Apache Cassandra
>> co-founder of Riptano, the source for professional Cassandra support
>> http://riptano.com
>
>
Strange your code looks just like mine. Possibly check your
configuration file and make sure you cluster is using framed mode.

package hpcas.c03;
import org.apache.cassandra.thrift.Cassandra;
import org.apache.thrift.protocol.*;
import org.apache.thrift.transport.*;
public class FramedConnWrapper {
    private TTransport transport;
    private TProtocol proto;
    private TSocket socket;
    public FramedConnWrapper(String host, int port) {
        socket =3D new TSocket(host,port);
        transport =3D new TFramedTransport(socket);
        proto =3D new TBinaryProtocol(transport);
    }
    public void open() throws Exception {
        transport.open();
    }
    public void close() throws Exception {
        transport.close();
        socket.close();
    }
    public Cassandra.Client getClient() {
        Cassandra.Client client =3D new Cassandra.Client(proto);
        return client;
    }
}