Class: ThriftFlumeEventServer::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/flume-logger/flume-og/thrift_flume_event_server.rb

Instance Method Summary collapse

Instance Method Details

#process_append(seqid, iprot, oprot) ⇒ Object 



40
41
42
43
44
 
# 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) ⇒ Object 



46
47
48
49
50
51
 
# 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