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 



74
75
76
77
78
79
80
81
82
 
# File 'lib/logstash/outputs/courier.rb', line 74

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
67
68
69
70
 
# File 'lib/logstash/outputs/courier.rb', line 53

def register
  @logger.info 'Starting courier output'

  options = {
    logger:             @logger,
    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,
  }

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