Merge pull request resque#675 from KensoDev/master

Work I have done on Resque, into a single Pull Request

Author: steveklabnik

README.md

@@ -58,6 +58,7 @@ Table Of Contents
       * [Mysql::Error: MySQL server has gone away](#section_Workers_Mysql_Error_MySQL_server_has_gone_away)
    * [The Front End](#section_The_Front_End)
       * [Standalone](#section_The_Front_End_Standalone)
+      * [Using the front end for failure review](#section_Using_The_Front_End_For_Review)
       * [Passenger](#section_The_Front_End_Passenger)
       * [Rack::URLMap](#section_The_Front_End_Rack_URLMap)
       * [Rails 3](#section_The_Front_End_Rails_3)
@@ -535,7 +536,21 @@ or set the Redis connection string if you need to do something like select a dif
 
     $ resque-web -p 8282 -r localhost:6379:2
 
+<a name='section_Using_The_Front_End_For_Review'></a>
+
+### Using The front end for failures review
+
+Using the front end to review what's happening in the queue
+-----------------------------------------------------------
+After using Resque for a while, you may have quite a few failed jobs.
+Reviewing them by going over pages when showing 20 a page can be a bit hard.
+
+You can change the param in the url (in the failed view only for now), just add per_page=100 and you will see 100 per page.
+for example: http://www.your_domain.com/resque/failed?start=20&per_page=200.
+
+
 <a name='section_The_Front_End_Passenger'></a>
+
 ### Passenger
 
 Using Passenger? Resque ships with a `config.ru` you can use. See

lib/resque/failure.rb

@@ -62,6 +62,10 @@ def self.clear
     def self.requeue(index)
       backend.requeue(index)
     end
+    
+    def self.requeue_to(index, queue_name)
+      backend.requeue(index, queue_name)
+    end
 
     def self.remove(index)
       backend.remove(index)

lib/resque/failure/redis.rb

@@ -35,6 +35,13 @@ def self.requeue(index)
         Resque.redis.lset(:failed, index, Resque.encode(item))
         Job.create(item['queue'], item['payload']['class'], *item['payload']['args'])
       end
+      
+      def self.requeue_to(index, queue_name)
+        item = all(index)
+        item['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S")
+        Resque.redis.lset(:failed, index, Resque.encode(item))
+        Job.create(queue_name, item['payload']['class'], *item['payload']['args'])
+      end
 
       def self.remove(index)
         id = rand(0xffffff)

lib/resque/server/views/failed.erb

@@ -1,5 +1,6 @@
-<%start = params[:start].to_i %>
-<%failed = Resque::Failure.all(start, 20)%>
+<% start = params[:start].to_i %>
+<% per_page = (params[:per_page].to_i > 0) ? params[:per_page].to_i : 20 %>
+<% failed = Resque::Failure.all(start, per_page) %>
 <% index = 0 %>
 <% date_format = "%Y/%m/%d %T %z" %>
 
@@ -13,7 +14,7 @@
 </form>
 <%end%>
 
-<p class='sub'>Showing <%=start%> to <%= start + 20 %> of <b><%= size = Resque::Failure.count %></b> jobs</p>
+<p class='sub'>Showing <%=start%> to <%= start + per_page %> of <b><%= size = Resque::Failure.count %></b> jobs</p>
 
 <ul class='failed'>
   <%for job in failed%>
@@ -63,5 +64,4 @@
   <%end%>
 </ul>
 
-<%= partial :next_more, :start => start, :size => size %>
-
+<%= partial :next_more, :start => start, :size => size, :per_page => per_page %>

lib/resque/server/views/next_more.erb

@@ -1,4 +1,4 @@
-<%if  start - 20 >= 0 || start + 20 <= size%>
+<% if  start - 20 >= 0 || start + 20 <= size %>
 <p class='pagination'>
   <% if start - 20 >= 0 %>
     <a href="<%= current_page %>?start=<%= start - 20 %>" class='less'>&laquo; less</a>