Examples of writeMessageBegin()

Examples of com.facebook.thrift.protocol.TProtocol.writeMessageBegin()

348
349
350
351
352
353
354
355
356
357
358
    for (TMessage msg : msgs) {
      TMemoryBuffer buf = new TMemoryBuffer(0);
      TProtocol proto = factory.getProtocol(buf);
      TMessage output = null;

      proto.writeMessageBegin(msg);
      proto.writeMessageEnd();

      output = proto.readMessageBegin();

      if (!msg.equals(output)) {
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

501
502
503
504
505
506
507
508
509
510
511
            protocol.getTransport().flush();
            // header size
            headerLength = bos.size();

            // message body
            protocol.writeMessageBegin( message );
            args.write( protocol );
            protocol.writeMessageEnd();
            protocol.getTransport().flush();
            int oldIndex = messageLength = bos.size();
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

658
659
660
661
662
663
664
665
666
667
668
            protocol.writeI64( response.getId() );
            protocol.getTransport().flush();
            headerLength = bos.size();

            // message
            protocol.writeMessageBegin( message );
            switch ( message.type ) {
                case TMessageType.EXCEPTION:
                    applicationException.write( protocol );
                    break;
                case TMessageType.REPLY:
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

502
503
504
505
506
507
508
509
510
511
512
            protocol.getTransport().flush();
            // header size
            headerLength = bos.size();

            // message body
            protocol.writeMessageBegin( message );
            args.write( protocol );
            protocol.writeMessageEnd();
            protocol.getTransport().flush();
            int oldIndex = messageLength = bos.size();
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

658
659
660
661
662
663
664
665
666
667
668
            protocol.writeI64( response.getId() );
            protocol.getTransport().flush();
            headerLength = bos.size();

            // message
            protocol.writeMessageBegin( message );
            switch ( message.type ) {
                case TMessageType.EXCEPTION:
                    applicationException.write( protocol );
                    break;
                case TMessageType.REPLY:
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

396
397
398
399
400
401
402
403
404
405
406
        Demo.echoString_args args = new Demo.echoString_args(  );
        args.setArg( "Hell, World!" );

        TMessage message = new TMessage( "echoString", TMessageType.CALL, ThriftCodec.getSeqId() );

        protocol.writeMessageBegin( message );
        args.write( protocol );
        protocol.writeMessageEnd();
        protocol.getTransport().flush();
        int oldIndex = messageLength = bos.size();
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

143
144
145
146
147
148
149
150
151
152
153
        protocol.writeString( Demo.Iface.class.getName() );
        protocol.writeI64( request.getId() );
        protocol.getTransport().flush();
        headerLength = bos.size();

        protocol.writeMessageBegin( message );
        methodResult.write( protocol );
        protocol.writeMessageEnd();
        protocol.getTransport().flush();
        int oldIndex = messageLength = bos.size();
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

216
217
218
219
220
221
222
223
224
225
226
        protocol.writeString( Demo.class.getName() );
        protocol.writeI64( request.getId() );
        protocol.getTransport().flush();
        headerLength = bos.size();

        protocol.writeMessageBegin( message );
        exception.write( protocol );
        protocol.writeMessageEnd();
        protocol.getTransport().flush();
        int oldIndex = messageLength = bos.size();
View Full Code Here

Examples of org.apache.thrift.protocol.TBinaryProtocol.writeMessageBegin()

72
73
74
75
76
77
78
79
80
81
82
    private <T extends TTransport> T writeFirstChunk(T outTransport) throws TException
    {
        TProtocol outProtocol = new TBinaryProtocol(outTransport);

        outProtocol.writeMessageBegin(new TMessage());
        outProtocol.writeString("hello world");

        return outTransport;
    }
View Full Code Here

Examples of org.apache.thrift.protocol.TProtocol.writeMessageBegin()

347
348
349
350
351
352
353
354
355
356
357
    for (TMessage msg : msgs) {
      TMemoryBuffer buf = new TMemoryBuffer(0);
      TProtocol proto = factory.getProtocol(buf);
      TMessage output = null;
     
      proto.writeMessageBegin(msg);
      proto.writeMessageEnd();

      output = proto.readMessageBegin();

      if (!msg.equals(output)) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.