Sha256: a0be11cdb29513f5955cfabfb4eed3abd194a0916278d6e534be06b17d88440f
Contents?: true
Size: 567 Bytes
Versions: 12
Compression:
Stored size: 567 Bytes
Contents
# encoding: utf-8
require "socket"
module LogStash::Inputs::Test
class UDPClient
attr_reader :host, :port, :socket
def initialize(port)
@port = port
@host = "0.0.0.0"
@socket = UDPSocket.new
socket.connect(host, port)
end
def send(msg="")
begin
send(msg)
rescue Exception => e
puts "send.exception", e
retry
end
end
def send(msg)
socket.connect(host, port) if socket.closed?
socket.send(msg, 0)
end
def close
socket.close
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems