Method: LogstashRails::Transport::LogstashTcp#push

Defined in:
lib/logstash_rails/transport/logstash_tcp.rb

#push(json_event) ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/logstash_rails/transport/logstash_tcp.rb', line 12

def push(json_event)
  @socket.write(json_event)
rescue Errno::EPIPE, Errno::ECONNREFUSED, NoMethodError => e
  log(e)
  connect!
  retry
end