Method: Fluent::Plugin::TcpSocketOutput#start_service_thread

Defined in:
lib/fluent/plugin/out_tcp_socket.rb

#start_service_thread ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
 
# File 'lib/fluent/plugin/out_tcp_socket.rb', line 49

def start_service_thread
   log.info "TCP Plugin thread started for %s:%s" % [hostname, port]
   while record = @@queue.deq
      begin
        get_client.puts record
      rescue
        log.error "client error %s" %[$!]
        @@socket = nil
        @@queue.enq record
      end
   end
end