Module: DatWorkerPool::Worker::ClassMethods

Defined in:
lib/dat-worker-pool/worker.rb

Instance Method Summary collapse

Instance Method Details

#after_work(&block) ⇒ Object 



31
 
# File 'lib/dat-worker-pool/worker.rb', line 31

def after_work(&block);     self.after_work_callbacks     << block; end

#after_work_callbacks ⇒ Object 



23
 
# File 'lib/dat-worker-pool/worker.rb', line 23

def after_work_callbacks;     @after_work_callbacks     ||= []; end

#before_work(&block) ⇒ Object 



30
 
# File 'lib/dat-worker-pool/worker.rb', line 30

def before_work(&block);    self.before_work_callbacks    << block; end

#before_work_callbacks ⇒ Object 



22
 
# File 'lib/dat-worker-pool/worker.rb', line 22

def before_work_callbacks;    @before_work_callbacks    ||= []; end

#on_available(&block) ⇒ Object 



27
 
# File 'lib/dat-worker-pool/worker.rb', line 27

def on_available(&block);   self.on_available_callbacks   << block; end

#on_available_callbacks ⇒ Object 



19
 
# File 'lib/dat-worker-pool/worker.rb', line 19

def on_available_callbacks;   @on_available_callbacks   ||= []; end

#on_error(&block) ⇒ Object 



29
 
# File 'lib/dat-worker-pool/worker.rb', line 29

def on_error(&block);       self.on_error_callbacks       << block; end

#on_error_callbacks ⇒ Object 



21
 
# File 'lib/dat-worker-pool/worker.rb', line 21

def on_error_callbacks;       @on_error_callbacks       ||= []; end

#on_shutdown(&block) ⇒ Object 



26
 
# File 'lib/dat-worker-pool/worker.rb', line 26

def on_shutdown(&block);    self.on_shutdown_callbacks    << block; end

#on_shutdown_callbacks ⇒ Object 



18
 
# File 'lib/dat-worker-pool/worker.rb', line 18

def on_shutdown_callbacks;    @on_shutdown_callbacks    ||= []; end

#on_start(&block) ⇒ Object 



25
 
# File 'lib/dat-worker-pool/worker.rb', line 25

def on_start(&block);       self.on_start_callbacks       << block; end

#on_start_callbacks ⇒ Object 



17
 
# File 'lib/dat-worker-pool/worker.rb', line 17

def on_start_callbacks;       @on_start_callbacks       ||= []; end

#on_unavailable(&block) ⇒ Object 



28
 
# File 'lib/dat-worker-pool/worker.rb', line 28

def on_unavailable(&block); self.on_unavailable_callbacks << block; end

#on_unavailable_callbacks ⇒ Object 



20
 
# File 'lib/dat-worker-pool/worker.rb', line 20

def on_unavailable_callbacks; @on_unavailable_callbacks ||= []; end

#prepend_after_work(&block) ⇒ Object 



39
 
# File 'lib/dat-worker-pool/worker.rb', line 39

def prepend_after_work(&block);     self.after_work_callbacks.unshift(block);     end

#prepend_before_work(&block) ⇒ Object 



38
 
# File 'lib/dat-worker-pool/worker.rb', line 38

def prepend_before_work(&block);    self.before_work_callbacks.unshift(block);    end

#prepend_on_available(&block) ⇒ Object 



35
 
# File 'lib/dat-worker-pool/worker.rb', line 35

def prepend_on_available(&block);   self.on_available_callbacks.unshift(block);   end

#prepend_on_error(&block) ⇒ Object 



37
 
# File 'lib/dat-worker-pool/worker.rb', line 37

def prepend_on_error(&block);       self.on_error_callbacks.unshift(block);       end

#prepend_on_shutdown(&block) ⇒ Object 



34
 
# File 'lib/dat-worker-pool/worker.rb', line 34

def prepend_on_shutdown(&block);    self.on_shutdown_callbacks.unshift(block);    end

#prepend_on_start(&block) ⇒ Object 



33
 
# File 'lib/dat-worker-pool/worker.rb', line 33

def prepend_on_start(&block);       self.on_start_callbacks.unshift(block);       end

#prepend_on_unavailable(&block) ⇒ Object 



36
 
# File 'lib/dat-worker-pool/worker.rb', line 36

def prepend_on_unavailable(&block); self.on_unavailable_callbacks.unshift(block); end