Module: PerfectQueue::TaskMonitorHook

Defined in:
lib/perfectqueue/task_monitor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#heartbeat_message ⇒ Object

Returns the value of attribute heartbeat_message.



166
167
168
 
# File 'lib/perfectqueue/task_monitor.rb', line 166

def heartbeat_message
  @heartbeat_message
end

#log ⇒ Object

Returns the value of attribute log.



156
157
158
 
# File 'lib/perfectqueue/task_monitor.rb', line 156

def log
  @log
end

#runner ⇒ Object

Returns the value of attribute runner.



158
159
160
 
# File 'lib/perfectqueue/task_monitor.rb', line 158

def runner
  @runner
end

#task_monitor ⇒ Object

Returns the value of attribute task_monitor.



157
158
159
 
# File 'lib/perfectqueue/task_monitor.rb', line 157

def task_monitor
  @task_monitor
end

Instance Method Details

#cancel_request!(*args, &block) ⇒ Object 



189
190
191
192
193
194
 
# File 'lib/perfectqueue/task_monitor.rb', line 189

def cancel_request!(*args, &block)
  @log.info "cancel request task=#{self.key}" if @log
  @task_monitor.task_finished(self) {
    super(*args, &block)
  }
end

#finish!(*args, &block) ⇒ Object 



168
169
170
171
172
173
 
# File 'lib/perfectqueue/task_monitor.rb', line 168

def finish!(*args, &block)
  @log.info "finished task=#{self.key}" if @log
  @task_monitor.task_finished(self) {
    super(*args, &block)
  }
end

#release!(*args, &block) ⇒ Object 



175
176
177
178
179
180
 
# File 'lib/perfectqueue/task_monitor.rb', line 175

def release!(*args, &block)
  @log.info "release task=#{self.key}" if @log
  @task_monitor.task_finished(self) {
    super(*args, &block)
  }
end

#retry!(*args, &block) ⇒ Object 



182
183
184
185
186
187
 
# File 'lib/perfectqueue/task_monitor.rb', line 182

def retry!(*args, &block)
  @log.info "retry task=#{self.key}" if @log
  @task_monitor.task_finished(self) {
    super(*args, &block)
  }
end