class Radar::App::MultiplexedProcessor
Public Instance Methods
process(iprot, oprot)
click to toggle source
Calls superclass method
# File lib/radar/app/multiplexed_processor.rb, line 2 def process(iprot, oprot) begin name, type, seqid = iprot.read_message_begin super(Thrift::StoredMessageProtocol.new(iprot, [name, type, seqid]), oprot) rescue Thrift::Exception => e write_error(Thrift::ApplicationException.new(Thrift::ApplicationException::INTERNAL_ERROR, e.message), oprot, name, seqid) end end
Protected Instance Methods
write_error(err, oprot, name, seqid)
click to toggle source
# File lib/radar/app/multiplexed_processor.rb, line 13 def write_error(err, oprot, name, seqid) oprot.write_message_begin(name, Thrift::MessageTypes::EXCEPTION, seqid) err.write(oprot) oprot.write_message_end oprot.trans.flush end