Sha256: e643c31ece1d7ffd29e47fdef7bd7f1c4d60914e420060bb420030052cc51ccf
Contents?: true
Size: 858 Bytes
Versions: 28
Compression:
Stored size: 858 Bytes
Contents
# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/rpm/blob/master/LICENSE for complete details.
require 'sidekiq'
require 'sidekiq/cli'
class SidekiqServer
include Singleton
attr_reader :queue_name
def initialize
@queue_name = "sidekiq#{Process.pid}"
@sidekiq = Sidekiq::CLI.instance
end
def run(file="test_worker.rb")
@sidekiq.parse(["--require", File.join(File.dirname(__FILE__), file),
"--queue", "#{queue_name},1"])
@cli_thread = Thread.new { @sidekiq.run }
end
# If we just let the process go away, occasional timing issues cause the
# Launcher actor in Sidekiq to throw a fuss and exit with a failed code.
def stop
puts "Trying to stop Sidekiq gracefully from #{$$}"
Process.kill("INT", $$)
@cli_thread.join
end
end
Version data entries
28 entries across 28 versions & 2 rubygems