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"])
    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"
    @sidekiq.launcher.stop
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
newrelic_rpm-3.9.4.245	test/multiverse/suites/sidekiq/sidekiq_server.rb
newrelic_rpm-3.9.3.241	test/multiverse/suites/sidekiq/sidekiq_server.rb
newrelic_rpm-3.9.2.239	test/multiverse/suites/sidekiq/sidekiq_server.rb
newrelic_rpm-3.9.1.236	test/multiverse/suites/sidekiq/sidekiq_server.rb
newrelic_rpm-3.9.0.229	test/multiverse/suites/sidekiq/sidekiq_server.rb