module Resque::Plugins::Serializer::Serializers::Both
Public Instance Methods
after_dequeue_clear_queue_lock(*args)
click to toggle source
# File lib/resque-serializer/serializers/both.rb, line 25 def after_dequeue_clear_queue_lock(*args) queue_mutex(args).unlock end
around_perform_clear_job_lock(*args) { || ... }
click to toggle source
# File lib/resque-serializer/serializers/both.rb, line 29 def around_perform_clear_job_lock(*args) yield ensure job_mutex(args).unlock end
before_dequeue_set_job_lock(*args)
click to toggle source
# File lib/resque-serializer/serializers/both.rb, line 21 def before_dequeue_set_job_lock(*args) job_mutex(args).lock end
before_enqueue_set_queue_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/both.rb, line 17 def before_enqueue_set_queue_lock(*args) queue_mutex(args).lock end
Private Instance Methods
job_key(args)
click to toggle source
# File lib/resque-serializer/serializers/both.rb, line 58 def job_key(args) klass = self.name.tableize.singularize args = args.map(&:to_s).join(',') "resque-serializer:job:#{klass}:#{args}" end
job_mutex(args)
click to toggle source
# File lib/resque-serializer/serializers/both.rb, line 47 def job_mutex(args) mutex_generator.call(job_key(args)) end
queue_key(args)
click to toggle source
# File lib/resque-serializer/serializers/both.rb, line 51 def queue_key(args) klass = self.name.tableize.singularize args = args.map(&:to_s).join(',') "resque-serializer:queue:#{klass}:#{args}" end
queue_mutex(args)
click to toggle source
# File lib/resque-serializer/serializers/both.rb, line 43 def queue_mutex(args) mutex_generator.call(queue_key(args)) end