module Thrift::Processor
Public Class Methods
new(handler)
click to toggle source
# File lib/thrift/processor.rb 22 def initialize(handler) 23 @handler = handler 24 end
Public Instance Methods
process(iprot, oprot)
click to toggle source
# File lib/thrift/processor.rb 26 def process(iprot, oprot) 27 name, type, seqid = iprot.read_message_begin 28 if respond_to?("process_#{name}") 29 send("process_#{name}", seqid, iprot, oprot) 30 true 31 else 32 iprot.skip(Types::STRUCT) 33 iprot.read_message_end 34 x = ApplicationException.new(ApplicationException::UNKNOWN_METHOD, 'Unknown function '+name) 35 oprot.write_message_begin(name, MessageTypes::EXCEPTION, seqid) 36 x.write(oprot) 37 oprot.write_message_end 38 oprot.trans.flush 39 false 40 end 41 end
read_args(iprot, args_class)
click to toggle source
# File lib/thrift/processor.rb 43 def read_args(iprot, args_class) 44 args = args_class.new 45 args.read(iprot) 46 iprot.read_message_end 47 args 48 end
write_result(result, oprot, name, seqid)
click to toggle source
# File lib/thrift/processor.rb 50 def write_result(result, oprot, name, seqid) 51 oprot.write_message_begin(name, MessageTypes::REPLY, seqid) 52 result.write(oprot) 53 oprot.write_message_end 54 oprot.trans.flush 55 end