Module: Resque::Plugins::Serializer::Serializers::Both
- Defined in:
- lib/resque-serializer/serializers/both.rb
Instance Method Summary collapse
- #after_dequeue_clear_queue_lock(*args) ⇒ Object
- #around_perform_clear_job_lock(*args) ⇒ Object
- #before_dequeue_set_job_lock(*args) ⇒ Object
-
#before_enqueue_set_queue_lock(*args) ⇒ Object
before_enqueue: ✓ enqueue: | after_enqueue: | before_dequeue: | ✓ dequeue: | | after_dequeue: ✗ | before_perform: | perform: | after_perform: ✗.
Instance Method Details
#after_dequeue_clear_queue_lock(*args) ⇒ Object
25 26 27 |
# 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) ⇒ Object
29 30 31 32 33 |
# 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) ⇒ Object
21 22 23 |
# 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) ⇒ Object
before_enqueue: ✓
enqueue: |
after_enqueue: |
before_dequeue: | ✓
dequeue: | |
after_dequeue: ✗ |
before_perform: |
perform: |
after_perform: ✗
17 18 19 |
# File 'lib/resque-serializer/serializers/both.rb', line 17 def before_enqueue_set_queue_lock(*args) queue_mutex(args).lock end |