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