Sha256: 07318ddb00e941b05b202fa22cd6044e2807b80c84a3e4fbdb0ca441f1f6ce4e
Contents?: true
Size: 471 Bytes
Versions: 3
Compression:
Stored size: 471 Bytes
Contents
require 'sidekiq-lock' class SyncMailWorker include Sidekiq::Worker include Sidekiq::Lock::Worker include Sidetiq::Schedulable sidekiq_options :queue => :email_queue, :retry => false, :backtrace => true sidekiq_options lock: { timeout: 120000, name: 'lock-mail-worker' } recurrence { minutely } def perform if lock.acquire! begin Mastiff::Email.sync_messages ensure lock.release! end end end end
Version data entries
3 entries across 3 versions & 1 rubygems