Class: LogstashRails::Transport::LogstashUdp

Inherits:
LogstashRails::TransportBase show all
Defined in:
lib/logstash_rails/transport/logstash_udp.rb

Instance Method Summary collapse

Methods inherited from LogstashRails::TransportBase

#destroy

Constructor Details

#initialize(formatter, options = {}) ⇒ LogstashUdp

Returns a new instance of LogstashUdp.



5
6
7
8
9
10
11
12
 
# File 'lib/logstash_rails/transport/logstash_udp.rb', line 5

def initialize(formatter, options = {})
  host = options[:host] || 'localhost'
  port = options[:port] || 9999

  @socket = UDPSocket.new.tap{|s| s.connect(host, port) }

  super
end

Instance Method Details

#push(json_event) ⇒ Object 



14
15
16
 
# File 'lib/logstash_rails/transport/logstash_udp.rb', line 14

def push(json_event)
  @socket.write(json_event)
end