Module: Resque::Plugins::Serializer::Serializers::Queue

Defined in:
lib/resque-serializer/serializers/queue.rb

Instance Method Summary collapse

Instance Method Details

#after_dequeue_clear_lock(*args) ⇒ Object



21
22
23
# File 'lib/resque-serializer/serializers/queue.rb', line 21

def after_dequeue_clear_lock(*args)
  mutex(args).unlock
end

#before_enqueue_set_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/queue.rb', line 17

def before_enqueue_set_lock(*args)
  mutex(args).lock
end