# File lib/thrift/client.rb, line 22 def initialize(iprot, oprot=nil) @iprot = iprot @oprot = oprot || iprot @seqid = 0 end
# File lib/thrift/client.rb, line 62 def handle_exception(mtype) if mtype == MessageTypes::EXCEPTION x = ApplicationException.new x.read(@iprot) @iprot.read_message_end raise x end end
# File lib/thrift/client.rb, line 53 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 lib/thrift/client.rb, line 28 def send_message(name, args_class, args = {}) @oprot.write_message_begin(name, MessageTypes::CALL, @seqid) send_message_args(args_class, args) end
# File lib/thrift/client.rb, line 38 def send_message_args(args_class, args) 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
# File lib/thrift/client.rb, line 33 def send_oneway_message(name, args_class, args = {}) @oprot.write_message_begin(name, MessageTypes::ONEWAY, @seqid) send_message_args(args_class, args) end