Class: SuckerPunch::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/sucker_punch/queue.rb,
lib/sucker_punch/testing.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name) ⇒ Queue

Returns a new instance of Queue.



5
6
7
 
# File 'lib/sucker_punch/queue.rb', line 5

def initialize(name)
  @name = name
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(name, *args, &block) ⇒ Object 



25
26
27
 
# File 'lib/sucker_punch/queue.rb', line 25

def method_missing(method_name, *args, &block)
  Celluloid::Actor[name].send(method_name, *args, &block)
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



3
4
5
 
# File 'lib/sucker_punch/queue.rb', line 3

def name
  @name
end

Class Method Details

.[](name) ⇒ Object 



9
10
11
 
# File 'lib/sucker_punch/queue.rb', line 9

def self.[](name)
  Celluloid::Actor[name]
end

Instance Method Details

#async ⇒ Object 



36
37
38
 
# File 'lib/sucker_punch/testing.rb', line 36

def async
  self
end

#jobs ⇒ Object 



32
33
34
 
# File 'lib/sucker_punch/testing.rb', line 32

def jobs
  SuckerPunch.queues[@name]
end

#register(klass, size) ⇒ Object 



13
14
15
16
17
18
19
 
# File 'lib/sucker_punch/queue.rb', line 13

def register(klass, size)
  Celluloid::Actor[name] = if size
                              klass.send(:pool, size: size)
                            else
                              klass.send(:pool)
                            end
end

#workers ⇒ Object 



21
22
23
 
# File 'lib/sucker_punch/queue.rb', line 21

def workers
  size
end