81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
# File 'lib/logstash/inputs/courier.rb', line 81
def register
@logger.info 'Starting courier input listener', :address => "#{@host}:#{@port}"
options = {
logger: @logger,
address: @host,
port: @port,
transport: @transport,
ssl_certificate: @ssl_certificate,
ssl_key: @ssl_key,
ssl_key_passphrase: @ssl_key_passphrase,
ssl_verify: @ssl_verify,
ssl_verify_default_ca: @ssl_verify_default_ca,
ssl_verify_ca: @ssl_verify_ca,
curve_secret_key: @curve_secret_key,
}
options[:max_packet_size] = @max_packet_size unless @max_packet_size.nil?
options[:peer_recv_queue] = @peer_recv_queue unless @peer_recv_queue.nil?
options[:add_peer_fields] = @add_peer_fields unless @add_peer_fields.nil?
require 'log-courier/server'
@log_courier = LogCourier::Server.new options
end
|