Sha256: 6fff1b34424ebde14a9cb43020438a37589c149cdfd60b0e7288ab2754a545ce

Contents?: true

Size: 483 Bytes

Versions: 4

Compression:

Stored size: 483 Bytes

Contents

require 'qs'

ENV['LOG_NAME'] = 'log/bench_dispatcher_daemon.log'
require 'bench/setup'

class DispatcherDaemon
  include Qs::Daemon

  name     'bench-dispatcher'
  pid_file ROOT_PATH.join('tmp/bench_dispatcher_daemon.pid').to_s

  logger LOGGER
  verbose_logging false

  queue Qs.dispatcher_queue

  # if fails notify the bench report so it doesn't hang forever on IO.select
  error do |exception, context|
    PROGRESS_IO.write_nonblock('F')
  end

end

run DispatcherDaemon.new

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
qs-0.6.1 bench/dispatcher.qs
qs-0.6.0 bench/dispatcher.qs
qs-0.5.0 bench/dispatcher.qs
qs-0.4.0 bench/dispatcher.qs