class ThriftFlumeEventServer::Processor

Public Instance Methods

process_append(seqid, iprot, oprot) click to toggle source
# File lib/flume-logger/flume-og/thrift_flume_event_server.rb, line 40
def process_append(seqid, iprot, oprot)
  args = read_args(iprot, Append_args)
  @handler.append(args.evt)
  return
end
process_close(seqid, iprot, oprot) click to toggle source
# File lib/flume-logger/flume-og/thrift_flume_event_server.rb, line 46
def process_close(seqid, iprot, oprot)
  args = read_args(iprot, Close_args)
  result = Close_result.new()
  @handler.close()
  write_result(result, oprot, 'close', seqid)
end