gistfile1.txt

class UDPRecipient < Valuable
  has_value :ip, :allow_blank => false
  has_value :port, :default => 11235
  has_value :logger, :default => Logger.new('./udp.log')
  has_value :max_message_size, :default => 2**10

  def udp_socket
    @udp ||= UDPSocket.new.tap do |udp|
      raise "Please supply an ip to UDPRecipient, like UDPRecipient.new(ip: '1.2.3.4')" unless ip
      udp.bind(ip, port)
      logger.warn "Listening at udp://#{ip}:#{port}"
    end
  end

  def listen
    begin
      message = udp.recvfrom(max_message_size)
      logger.debug message
      yield message if block_given?
    end while 1
  end

  def fire
    listen
  ensure
    logger.warn('closing connection')
    logger.try(:close)
  end
end