<% @subtabs = resque.queues unless partial? || params[:id].nil? %>
<% if queue = params[:id] %>
Jobs on <%= queue %>
<% unless resque.delayed_queue? queue %>
Showing <%= start = params[:start].to_i %> to <%= start + 20 %> of <%=size = resque.size(queue.to_sym)%> jobs
| Class |
Args |
Enqueued At |
<% for job in (jobs = resque.peek(queue.to_sym, start, 20)) %>
| <%= job['class'] %> |
<%=h job['args'].inspect %> |
<%=h enqueued_at(job['resque_enqueue_timestamp']) %> |
<% end %>
<% else %>
Showing <%= start = params[:start].to_i %> to <%= start + 20 %> of <%=size = resque.size(queue.to_sym)%> jobs
| Class |
Args |
Enqueued At |
Processes In |
<% for job in (jobs = resque.peek(queue.to_sym, start, 20, :all_sorted)) %>
| <%= job['class'] %> |
<%=h job['args'].inspect %> |
<%=h enqueued_at(job['resque_enqueue_timestamp']) %> |
<%=h processes_in(job['delay_until']) %> |
<% end %>
<% end %>
<% if jobs.empty? %>
| There are no pending jobs in this queue |
<% end %>
<%= partial :next_more, :start => start, :size => size %>
<% else %>
Queues
The list below contains all the registered queues with the number of jobs currently in the queue. Select a queue from above to view all jobs currently pending on the queue.
| Name |
Ready Jobs |
Delayed Jobs |
<% for queue in resque.queues.sort_by { |q| q.to_s } %>
| "><%= queue %> |
<%= resque.ready_size queue.to_sym %> |
<%= resque.delayed_size(queue.to_sym) if resque.delayed_queue?(queue) %> |
<% end %>
">
| failed |
<%= Resque::Failure.count %> |
<% end %>