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