Contents

class FnordMetric::Acceptor

  def initialize(opts)
    @opts = opts

    FnordMetric.register(self)
  end

  def initialized   
    inbound_class = if @opts[:protocol] == :udp 
      FnordMetric::UDPAcceptor
    else
      FnordMetric::TCPAcceptor
    end

    @opts[:listen] = [
      @opts[:host] || "0.0.0.0",
      @opts[:port] || 2323
    ]

    begin
      inbound_stream = inbound_class.start(@opts)
      FnordMetric.log "listening on #{@opts[:protocol]}://#{@opts[:listen][0..1].join(":")}"
    #rescue
    #  FnordMetric.log "cant start #{inbound_class.name}. port in use?"
    end
  end

end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
fnordmetric-1.0.1	lib/fnordmetric/acceptors/acceptor.rb
fnordmetric-1.0.0	lib/fnordmetric/acceptors/acceptor.rb
fnordmetric-0.9.7	lib/fnordmetric/acceptors/acceptor.rb