module Resque::Plugins::Serializer::Serializers::Queue

Public Instance Methods

after_dequeue_clear_lock(*args) click to toggle source
# File lib/resque-serializer/serializers/queue.rb, line 21
def after_dequeue_clear_lock(*args)
  mutex(args).unlock
end
before_enqueue_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/queue.rb, line 17
def before_enqueue_set_lock(*args)
  mutex(args).lock
end

Private Instance Methods

key(args) click to toggle source
# File lib/resque-serializer/serializers/queue.rb, line 37
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/queue.rb, line 33
def mutex(args)
  mutex_generator.call(key(args))
end