module Resque::Plugins::Serializer::Serializers::Job

Public Instance Methods

around_perform_clear_lock(*args) { || ... } click to toggle source
# File lib/resque-serializer/serializers/job.rb, line 21
def around_perform_clear_lock(*args)
  yield
ensure
  mutex(args).unlock
end
before_dequeue_set_lock(*args) click to toggle source

before_enqueue:

      enqueue:
after_enqueue:

before_dequeue: ✓

      dequeue: |
after_dequeue: |

before_perform: |

      perform: |
after_perform: ✗
# File lib/resque-serializer/serializers/job.rb, line 17
def before_dequeue_set_lock(*args)
  mutex(args).lock
end

Private Instance Methods

key(args) click to toggle source
# File lib/resque-serializer/serializers/job.rb, line 39
def key(args)
  klass = self.name.tableize.singularize
  args  = args.map(&:to_s).join(',')

  "resque-serializer:#{klass}:#{args}"
end
mutex(args) click to toggle source
# File lib/resque-serializer/serializers/job.rb, line 35
def mutex(args)
  mutex_generator.call(key(args))
end