|
2 | 2 |
|
3 | 3 | describe Sidekiq::QueuePause do |
4 | 4 | describe Sidekiq::QueuePause::PausingFetch do |
5 | | - describe "#unpause_queues_cmd" do |
6 | | - let(:queuename) { "some_queue" } |
7 | | - let(:config) { {queues: [queuename], strict: true} } |
8 | | - let(:pausing_fetch) { described_class.new(config) } |
| 5 | + let(:queue_name) { "some_queue" } |
| 6 | + let(:config) { {queues: [queue_name], strict: true} } |
| 7 | + |
| 8 | + subject(:pausing_fetch) { described_class.new(config) } |
9 | 9 |
|
| 10 | + describe "#unpause_queues_cmd" do |
10 | 11 | context "with Sidekiq > 6.5.6 the queues list can contain Hashes" do |
11 | | - let(:queue_list) { ["queue:#{queuename}", {timeout: 2}] } |
| 12 | + let(:queue_list) { ["queue:#{queue_name}", {timeout: 2}] } |
12 | 13 |
|
13 | 14 | before { allow(pausing_fetch).to receive(:queues_cmd).and_return(queue_list) } |
14 | 15 |
|
15 | 16 | it "does not checked whether the Hash is paused" do |
16 | | - expect(Sidekiq::QueuePause).to receive(:paused?).with(queuename, Sidekiq::QueuePause.process_key).and_return(false) |
| 17 | + expect(Sidekiq::QueuePause).to receive(:paused?).with(queue_name, Sidekiq::QueuePause.process_key).and_return(false) |
17 | 18 |
|
18 | 19 | expect(pausing_fetch.unpaused_queues_cmd).to match_array(queue_list) |
19 | 20 | end |
20 | 21 | end |
21 | 22 |
|
22 | 23 | context "with Sidekiq < 6.5.6 the queues list can contain an Integer" do |
23 | | - let(:queue_list) { ["queue:#{queuename}", 2] } |
| 24 | + let(:queue_list) { ["queue:#{queue_name}", 2] } |
24 | 25 |
|
25 | 26 | before { allow(pausing_fetch).to receive(:queues_cmd).and_return(queue_list) } |
26 | 27 |
|
27 | 28 | it "does not check whether the Integer is paused" do |
28 | | - expect(Sidekiq::QueuePause).to receive(:paused?).with(queuename, Sidekiq::QueuePause.process_key).and_return(false) |
| 29 | + expect(Sidekiq::QueuePause).to receive(:paused?).with(queue_name, Sidekiq::QueuePause.process_key).and_return(false) |
29 | 30 |
|
30 | 31 | expect(pausing_fetch.unpaused_queues_cmd).to match_array(queue_list) |
31 | 32 | end |
|
0 commit comments