mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
commit
43ae7d8833
2 changed files with 6 additions and 9 deletions
|
@ -43,7 +43,6 @@ class TestMiddleware < MiniTest::Unit::TestCase
|
||||||
end
|
end
|
||||||
|
|
||||||
it 'executes middleware in the proper order' do
|
it 'executes middleware in the proper order' do
|
||||||
recorder = []
|
|
||||||
msg = Sidekiq.dump_json({ 'class' => CustomWorker.to_s, 'args' => [$recorder] })
|
msg = Sidekiq.dump_json({ 'class' => CustomWorker.to_s, 'args' => [$recorder] })
|
||||||
|
|
||||||
Sidekiq.server_middleware do |chain|
|
Sidekiq.server_middleware do |chain|
|
||||||
|
|
|
@ -55,7 +55,6 @@ class TestStats < MiniTest::Unit::TestCase
|
||||||
|
|
||||||
processor = Sidekiq::Processor.new(boss)
|
processor = Sidekiq::Processor.new(boss)
|
||||||
|
|
||||||
pstr = processor.to_s
|
|
||||||
assert_raises RuntimeError do
|
assert_raises RuntimeError do
|
||||||
processor.process(msg, 'xyzzy')
|
processor.process(msg, 'xyzzy')
|
||||||
end
|
end
|
||||||
|
@ -71,24 +70,23 @@ class TestStats < MiniTest::Unit::TestCase
|
||||||
conn.rpush 'queue:foo', '{}'
|
conn.rpush 'queue:foo', '{}'
|
||||||
conn.sadd 'queues', 'foo'
|
conn.sadd 'queues', 'foo'
|
||||||
|
|
||||||
conn.rpush 'queue:bar', '{}'
|
3.times { conn.rpush 'queue:bar', '{}' }
|
||||||
conn.rpush 'queue:bar', '{}'
|
|
||||||
conn.sadd 'queues', 'bar'
|
conn.sadd 'queues', 'bar'
|
||||||
|
|
||||||
conn.rpush 'queue:baz', '{}'
|
2.times { conn.rpush 'queue:baz', '{}' }
|
||||||
conn.sadd 'queues', 'baz'
|
conn.sadd 'queues', 'baz'
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "queues_with_sizes" do
|
describe "queues_with_sizes" do
|
||||||
it "returns queue names and corresponding job counts" do
|
it "returns queue names and corresponding job counts" do
|
||||||
assert_equal [["foo", 1], ["baz", 1], ["bar", 2]], Sidekiq.info[:queues_with_sizes]
|
assert_equal [["foo", 1], ["baz", 2], ["bar", 3]], Sidekiq.info[:queues_with_sizes]
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "backlog" do
|
describe "backlog" do
|
||||||
it "returns count of all jobs yet to be processed" do
|
it "returns count of all jobs yet to be processed" do
|
||||||
assert_equal 4, Sidekiq.info[:backlog]
|
assert_equal 6, Sidekiq.info[:backlog]
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@ -97,8 +95,8 @@ class TestStats < MiniTest::Unit::TestCase
|
||||||
assert_equal 0, Sidekiq.size("foox")
|
assert_equal 0, Sidekiq.size("foox")
|
||||||
assert_equal 1, Sidekiq.size(:foo)
|
assert_equal 1, Sidekiq.size(:foo)
|
||||||
assert_equal 1, Sidekiq.size("foo")
|
assert_equal 1, Sidekiq.size("foo")
|
||||||
assert_equal 3, Sidekiq.size("foo", "bar")
|
assert_equal 4, Sidekiq.size("foo", "bar")
|
||||||
assert_equal 4, Sidekiq.size
|
assert_equal 6, Sidekiq.size
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Add table
Reference in a new issue