Module | Thrift::Processor |
In: |
ruby/lib/thrift/processor.rb
|
# File ruby/lib/thrift/processor.rb, line 22 22: def initialize(handler) 23: @handler = handler 24: end
# File ruby/lib/thrift/processor.rb, line 26 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
# File ruby/lib/thrift/processor.rb, line 43 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