mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Add optional count to queue display
This commit is contained in:
parent
f6adea534c
commit
5ebd9aee2d
2 changed files with 3 additions and 1 deletions
|
@ -27,6 +27,7 @@ end
|
||||||
executes all previously queued jobs. (panthomakos)
|
executes all previously queued jobs. (panthomakos)
|
||||||
- Sidekiq workers can be run inline during tests, just `require 'sidekiq/testing/inline'` (panthomakos)
|
- Sidekiq workers can be run inline during tests, just `require 'sidekiq/testing/inline'` (panthomakos)
|
||||||
- Queues can now be deleted from the Sidekiq web UI [#154]
|
- Queues can now be deleted from the Sidekiq web UI [#154]
|
||||||
|
- Fix unnecessary shutdown delay due to Retry Poller [#174]
|
||||||
|
|
||||||
1.1.4
|
1.1.4
|
||||||
-----------
|
-----------
|
||||||
|
|
|
@ -107,8 +107,9 @@ module Sidekiq
|
||||||
|
|
||||||
get "/queues/:name" do
|
get "/queues/:name" do
|
||||||
halt 404 unless params[:name]
|
halt 404 unless params[:name]
|
||||||
|
count = (params[:count] || 10).to_i
|
||||||
@name = params[:name]
|
@name = params[:name]
|
||||||
@messages = Sidekiq.redis {|conn| conn.lrange("queue:#{@name}", 0, 10) }.map { |str| Sidekiq.load_json(str) }
|
@messages = Sidekiq.redis {|conn| conn.lrange("queue:#{@name}", 0, count) }.map { |str| Sidekiq.load_json(str) }
|
||||||
slim :queue
|
slim :queue
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue