diff --git a/lib/gelf/transport/udp.rb b/lib/gelf/transport/udp.rb index 4f664e7..fbf23f0 100644 --- a/lib/gelf/transport/udp.rb +++ b/lib/gelf/transport/udp.rb @@ -31,12 +31,11 @@ def close def create_consumer_for host, port Thread.new do socket = UDPSocket.new(Addrinfo.ip(host).afamily) - socket.connect(host, port) loop do datagram = @q.pop break unless datagram - socket.send(datagram, 0) + socket.send(datagram, 0, host, port) end end end