Sha256: 40e5c46634efe73fb8b0b69cf7f1519af581095e3bc01008fd455038583c286a
Contents?: true
Size: 969 Bytes
Versions: 3
Compression:
Stored size: 969 Bytes
Contents
require 'helper' require 'sidekiq' require 'sidekiq/manager' # for TimedQueue require 'connection_pool' class TestManager < MiniTest::Unit::TestCase describe 'with redis' do before do Sidekiq.redis = REDIS Sidekiq.redis.flushdb $processed = 0 $mutex = Mutex.new end class IntegrationWorker include Sidekiq::Worker def perform(a, b) $mutex.synchronize do $processed += 1 end a + b end end it 'processes messages' do Sidekiq::Client.push(:foo, 'class' => IntegrationWorker, 'args' => [1, 2]) Sidekiq::Client.push(:foo, 'class' => IntegrationWorker, 'args' => [1, 3]) q = TimedQueue.new mgr = Sidekiq::Manager.new(:queues => [:foo], :concurrency => 2) mgr.when_done do |_| q << 'done' if $processed == 2 end mgr.start! result = q.timed_pop(1.0) assert_equal 'done', result mgr.stop end end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
sidekiq-0.10.0 | test/test_manager.rb |
sidekiq-0.9.1 | test/test_manager.rb |
sidekiq-0.9.0 | test/test_manager.rb |