Contents

module Delayed
  module Plugins
    class ClearLocks < Plugin
      callbacks do |lifecycle|
        lifecycle.around(:execute) do |worker, &block|
          begin
            block.call(worker)
          ensure            
            Delayed::Job.clear_locks!(worker.name)
          end
        end 
      end
    end
  end
end

Version data entries

10 entries across 10 versions & 2 rubygems

Version	Path
delayed_job_unique_key-0.0.4	lib/delayed/plugins/clear_locks.rb
delayed_job-3.0.1	lib/delayed/plugins/clear_locks.rb
delayed_job-3.0.0	lib/delayed/plugins/clear_locks.rb
delayed_job_unique_key-0.0.3	lib/delayed/plugins/clear_locks.rb
delayed_job_unique_key-0.0.2	lib/delayed/plugins/clear_locks.rb
delayed_job_unique_key-0.0.1	lib/delayed/plugins/clear_locks.rb
delayed_job-3.0.0.pre4	lib/delayed/plugins/clear_locks.rb
delayed_job-3.0.0.pre3	lib/delayed/plugins/clear_locks.rb
delayed_job-3.0.0.pre2	lib/delayed/plugins/clear_locks.rb
delayed_job-3.0.0.pre	lib/delayed/plugins/clear_locks.rb