Sha256: 66e6b68db312823f92a7a6f9941cd85195592e2c0fa5f1bcf096eddc3b9ed5c2

Contents?: true

Size: 312 Bytes

Versions: 2

Compression:

Stored size: 312 Bytes

Contents

module NFAgent
  class Server
    def initialize
      Log.info("Starting up")
      Submitter.start_resubmission_thread
      chunk_handler = ChunkHandler.new
      chunk_handler.periodically_check_expired

      EM.run {
        EM.start_server "0.0.0.0", 10000, Event, chunk_handler
      }
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
nfagent-0.9.0 lib/nfagent/server.rb
nfagent-0.0.99 lib/nfagent/server.rb