Class: Worker

Inherits:
Object
  • Object
show all
Defined in:
lib/tempest.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cluster, queue, &block) ⇒ Worker

Returns a new instance of Worker.



23
24
25
26
27
 
# File 'lib/tempest.rb', line 23

def initialize cluster, queue, &block
  @cluster = cluster
  @queue = queue
  instance_eval &block
end

Instance Attribute Details

#cluster ⇒ Object (readonly)

Returns the value of attribute cluster.



22
23
24
 
# File 'lib/tempest.rb', line 22

def cluster
  @cluster
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



22
23
24
 
# File 'lib/tempest.rb', line 22

def queue
  @queue
end

Instance Method Details

#on(action, &block) ⇒ Object 



29
30
31
 
# File 'lib/tempest.rb', line 29

def on action, &block
  @cluster.on action, &block
end

#start_loop ⇒ Object 



37
38
39
 
# File 'lib/tempest.rb', line 37

def start_loop
  @cluster.loop
end

#stop_loop ⇒ Object 



41
42
43
 
# File 'lib/tempest.rb', line 41

def stop_loop
  @cluster.loop = false
end

#work(action, respond_to, *args) ⇒ Object 



33
34
35
 
# File 'lib/tempest.rb', line 33

def work action, respond_to, *args
  @cluster.work @queue, action, *args, respond_to
end