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