Module: DatWorkerPool::Worker::ClassMethods

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

Instance Method Summary collapse

Instance Method Details

#after_work(&block) ⇒ Object 



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

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

#after_work_callbacks ⇒ Object 



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

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

#before_work(&block) ⇒ Object 



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

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

#before_work_callbacks ⇒ Object 



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

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

#on_available(&block) ⇒ Object 



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

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

#on_available_callbacks ⇒ Object 



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

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

#on_error(&block) ⇒ Object 



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

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

#on_error_callbacks ⇒ Object 



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

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

#on_shutdown(&block) ⇒ Object 



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

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

#on_shutdown_callbacks ⇒ Object 



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

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

#on_start(&block) ⇒ Object 



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

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

#on_start_callbacks ⇒ Object 



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

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

#on_unavailable(&block) ⇒ Object 



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

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

#on_unavailable_callbacks ⇒ Object 



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

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

#prepend_after_work(&block) ⇒ Object 



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

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

#prepend_before_work(&block) ⇒ Object 



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

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

#prepend_on_available(&block) ⇒ Object 



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

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

#prepend_on_error(&block) ⇒ Object 



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

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

#prepend_on_shutdown(&block) ⇒ Object 



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

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

#prepend_on_start(&block) ⇒ Object 



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

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

#prepend_on_unavailable(&block) ⇒ Object 



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

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