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