Class: LogStash::Outputs::Lumberjack

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/outputs/lumberjack.rb

Instance Method Summary collapse

Instance Method Details

#receive(event) ⇒ Object 



35
36
37
38
39
40
41
42
 
# File 'lib/logstash/outputs/lumberjack.rb', line 35

def receive(event)
  return unless output?(event)
  if event == LogStash::SHUTDOWN
    finished
    return
  end # LogStash::SHUTDOWN
  @codec.encode(event)
end

#register ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/logstash/outputs/lumberjack.rb', line 19

def register
  require 'lumberjack/client'
  connect

  @codec.on_event do |event, payload|
    begin
      @client.write({ 'line' => payload })
    rescue Exception => e
      @logger.error("Client write error, trying connect", :e => e, :backtrace => e.backtrace)
      connect
      retry
    end # begin
  end # @codec
end