| 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