Class: ActiveJob::LogSubscriber
- Inherits:
-
ActiveSupport::LogSubscriber
- Object
- ActiveSupport::LogSubscriber
- ActiveJob::LogSubscriber
- Defined in:
- lib/active_job/uniqueness/log_subscriber.rb
Overview
:nodoc:
Instance Method Summary collapse
- #conflict(event) ⇒ Object
- #lock(event) ⇒ Object
- #runtime_conflict(event) ⇒ Object
- #runtime_lock(event) ⇒ Object
- #runtime_unlock(event) ⇒ Object
- #unlock(event) ⇒ Object
Instance Method Details
#conflict(event) ⇒ Object
43 44 45 46 47 48 49 50 |
# File 'lib/active_job/uniqueness/log_subscriber.rb', line 43 def conflict(event) job = event.payload[:job] resource = event.payload[:resource] info do "Not unique #{lock_info(job, resource)}" + args_info(job) end end |
#lock(event) ⇒ Object
7 8 9 10 11 12 13 14 |
# File 'lib/active_job/uniqueness/log_subscriber.rb', line 7 def lock(event) job = event.payload[:job] resource = event.payload[:resource] debug do "Locked #{lock_info(job, resource)}" + args_info(job) end end |
#runtime_conflict(event) ⇒ Object
52 53 54 55 56 57 58 59 |
# File 'lib/active_job/uniqueness/log_subscriber.rb', line 52 def runtime_conflict(event) job = event.payload[:job] resource = event.payload[:resource] info do "Not unique runtime #{lock_info(job, resource)}" + args_info(job) end end |
#runtime_lock(event) ⇒ Object
16 17 18 19 20 21 22 23 |
# File 'lib/active_job/uniqueness/log_subscriber.rb', line 16 def runtime_lock(event) job = event.payload[:job] resource = event.payload[:resource] debug do "Locked runtime #{lock_info(job, resource)}" + args_info(job) end end |
#runtime_unlock(event) ⇒ Object
34 35 36 37 38 39 40 41 |
# File 'lib/active_job/uniqueness/log_subscriber.rb', line 34 def runtime_unlock(event) job = event.payload[:job] resource = event.payload[:resource] debug do "Unlocked runtime #{lock_info(job, resource)}" end end |
#unlock(event) ⇒ Object
25 26 27 28 29 30 31 32 |
# File 'lib/active_job/uniqueness/log_subscriber.rb', line 25 def unlock(event) job = event.payload[:job] resource = event.payload[:resource] debug do "Unlocked #{lock_info(job, resource)}" end end |