Sha256: cf5b15b1f03f3c2ca6c6d5a42feca1d494c2890940c2069cc826cef0e26eec7c
Contents?: true
Size: 687 Bytes
Versions: 46
Compression:
Stored size: 687 Bytes
Contents
# (c) Copyright IBM Corp. 2021
# (c) Copyright Instana Inc. 2017
require 'sidekiq/launcher'
require 'sidekiq/cli'
require 'sidekiq/api'
require 'sidekiq/processor'
require_relative 'jobs/sidekiq_job_1'
require_relative 'jobs/sidekiq_job_2'
::Instana.logger.info "Booting instrumented sidekiq worker for tests."
::Sidekiq.logger.level = ::Logger::FATAL
sidekiq_thread = Thread.new do
launcher = ::Sidekiq::Launcher.new(
::Sidekiq.options.merge(
queues: ['important'],
concurrency: 2
)
)
launcher.run
Thread.current[:worker] = launcher
end
Minitest.after_run do
::Instana.logger.info "Killing Sidekiq worker"
sidekiq_thread[:worker].stop
sleep 1
end
Version data entries
46 entries across 46 versions & 1 rubygems