Class: LogStash::Outputs::Courier

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

Overview

Send events using the Log Courier protocol

Instance Method Summary collapse

Instance Method Details

#receive(event) ⇒ Object 



67
68
69
70
71
72
73
74
75
 
# File 'lib/logstash/outputs/courier.rb', line 67

def receive(event)
  return unless output?(event)
  if event == LogStash::SHUTDOWN
    @client.shutdown
    finished
    return
  end
  @client.publish event.to_hash
end

#register ⇒ Object 



60
61
62
63
64
65
 
# File 'lib/logstash/outputs/courier.rb', line 60

def register
  @logger.info 'Starting courier output'

  require 'log-courier/client'
  @client = LogCourier::Client.new(options)
end