lib/sidekiq/api.rb in sidekiq-5.2.1 vs lib/sidekiq/api.rb in sidekiq-5.2.2
- old
+ new
@@ -668,9 +668,15 @@
def retry_all
while size > 0
each(&:retry)
end
end
+
+ def kill_all
+ while size > 0
+ each(&:kill)
+ end
+ end
end
##
# Allows enumeration of dead jobs within Sidekiq.
#