Skip to content

Commit d6591e9

Browse files
committed
Changed requeue to also remove from the queue
1 parent 4b0a835 commit d6591e9

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

lib/resque/failure.rb

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,11 @@ def self.requeue(index)
6363
backend.requeue(index)
6464
end
6565

66+
def self.requeue_and_remove(index)
67+
backend.requeue(index)
68+
backend.remove(index)
69+
end
70+
6671
def self.requeue_to(index, queue_name)
6772
backend.requeue(index, queue_name)
6873
end

lib/resque/server.rb

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -192,13 +192,14 @@ def show_for_polling(page)
192192

193193
post "/failed/requeue/all" do
194194
Resque::Failure.count.times do |num|
195-
Resque::Failure.requeue(num)
195+
Resque::Failure.requeue_and_remove(num)
196196
end
197197
redirect u('failed')
198198
end
199199

200200
get "/failed/requeue/:index/?" do
201-
Resque::Failure.requeue(params[:index])
201+
Resque::Failure.requeue_and_remove(params[:index])
202+
202203
if request.xhr?
203204
return Resque::Failure.all(params[:index])['retried_at']
204205
else

0 commit comments

Comments
 (0)