Sha256: 75e061d17e66b4fbb7c01f2333d9337002a552e0c0acf2322f0fed55b835512f

Contents?: true

Size: 650 Bytes

Versions: 33

Compression:

Stored size: 650 Bytes

Contents

require 'sidekiq/launcher'
require 'sidekiq/cli'
require 'sidekiq/api'
require 'sidekiq/processor'

require Dir.pwd + '/test/jobs/sidekiq_job_1.rb'
require Dir.pwd + '/test/jobs/sidekiq_job_2.rb'

::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 2
end

sleep 5

Version data entries

33 entries across 33 versions & 1 rubygems

Version Path
instana-1.7.10 test/servers/sidekiq/worker.rb
instana-1.7.9 test/servers/sidekiq/worker.rb
instana-1.7.8 test/servers/sidekiq/worker.rb
instana-1.7.7 test/servers/sidekiq/worker.rb
instana-1.7.6 test/servers/sidekiq/worker.rb
instana-1.7.5 test/servers/sidekiq/worker.rb
instana-1.7.4 test/servers/sidekiq/worker.rb
instana-1.7.3 test/servers/sidekiq/worker.rb
instana-1.7.2 test/servers/sidekiq/worker.rb
instana-1.7.1 test/servers/sidekiq/worker.rb
instana-1.7.0 test/servers/sidekiq/worker.rb
instana-1.6.1 test/servers/sidekiq/worker.rb
instana-1.6.0 test/servers/sidekiq/worker.rb