Contents

require 'socket'

module RTALogger
  # show log items on console out put
  class LogRepositoryUDP < LogRepository
    def initialize(host = '127.0.0.1', port = 4913)
      super()
      @host = host
      @port = port
    end

    protected

    def flush_and_clear
      semaphore.synchronize do
        u1 = UDPSocket.new
        u1.bind(@host, @port)
        @log_records.each { |log_record| u1.send log_record.to_s, 0, @host, @port }
        u1.close
      end
      super
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
RTALogger-0.1.4	lib/log_repository_udp.rb
RTALogger-0.1.3	lib/log_repository_udp.rb
RTALogger-0.1.2	lib/log_repository_udp.rb
RTALogger-0.1.1	lib/log_repository_udp.rb