# File usr/lib/ruby/vendor_ruby/thrift/client.rb, line 22 def initialize(iprot, oprot=nil) @iprot = iprot @oprot = oprot || iprot @seqid = 0 end
# File usr/lib/ruby/vendor_ruby/thrift/client.rb, line 53 def handle_exception(mtype) if mtype == MessageTypes::EXCEPTION x = ApplicationException.new x.read(@iprot) @iprot.read_message_end raise x end end
# File usr/lib/ruby/vendor_ruby/thrift/client.rb, line 44 def receive_message(result_klass) fname, mtype, rseqid = @iprot.read_message_begin handle_exception(mtype) result = result_klass.new result.read(@iprot) @iprot.read_message_end result end
# File usr/lib/ruby/vendor_ruby/thrift/client.rb, line 28 def send_message(name, args_class, args = {}) @oprot.write_message_begin(name, MessageTypes::CALL, @seqid) data = args_class.new args.each do |k, v| data.send("#{k.to_s}=", v) end begin data.write(@oprot) rescue StandardError => e @oprot.trans.close raise e end @oprot.write_message_end @oprot.trans.flush end