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()
      @udp_socket = UDPSocket.new
      @udp_socket.bind(host, port)
    end

    def load_config(config_json)
      super

      host = config_json['host'].to_s
      port = config_json['port'].nil? ? 4913 : config_json['port'].to_i
      @udp_socket = UDPSocket.new
      @udp_socket.bind(host, port)
    end

    # register :udp

    protected

    def flush_and_clear
      semaphore.synchronize do
        @log_records.each { |log_record| @udp_socket.send @formatter.format(log_record), 0, @host, @port }
      end
      super
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
RTALogger-2.4.0	lib/log_repository_udp.rb
RTALogger-2.3.1	lib/log_repository_udp.rb
RTALogger-2.3.0	lib/log_repository_udp.rb
RTALogger-2.2.2	lib/log_repository_udp.rb
RTALogger-2.2.0	lib/log_repository_udp.rb
RTALogger-2.1.2	lib/log_repository_udp.rb
RTALogger-2.1.1	lib/log_repository_udp.rb
RTALogger-2.1.0	lib/log_repository_udp.rb
RTALogger-2.0.2	lib/log_repository_udp.rb
RTALogger-2.0.1	lib/log_repository_udp.rb
RTALogger-2.0.0	lib/log_repository_udp.rb
RTALogger-1.1.1	lib/log_repository_udp.rb
RTALogger-1.1.0	lib/log_repository_udp.rb
RTALogger-1.0.0	lib/log_repository_udp.rb