Class: LogStash::Outputs::LogCourier

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 



70
71
72
73
74
75
76
77
78
 
# File 'lib/logstash/outputs/courier.rb', line 70

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

#register ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/logstash/outputs/courier.rb', line 53

def register
  require 'log-courier/client'

  @client = LogCourier::Client.new(
    addresses:          @hosts,
    port:               @port,
    ssl_ca:             @ssl_ca,
    ssl_certificate:    @ssl_certificate,
    ssl_key:            @ssl_key,
    ssl_key_passphrase: @ssl_key_passphrase,
    spool_size:         @spool_size,
    idle_timeout:       @idle_timeout
  )
end