Class: QPush::Server::WorkerConfig

Inherits:
Object
  • Object
show all
Defined in:
lib/qpush/server/config.rb

Constant Summary collapse

DEFAULTS = 
{
namespace: 'default',
priorities: 5,
queue_threads: 2,
perform_threads: 2,
delay_threads: 1 }.freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ WorkerConfig

Returns a new instance of WorkerConfig.



30
31
32
33
 
# File 'lib/qpush/server/config.rb', line 30

def initialize(options = {})
  options = DEFAULTS.merge(options)
  options.each { |key, value| send("#{key}=", value) }
end

Instance Attribute Details

#delay_threads ⇒ Object

Returns the value of attribute delay_threads.



27
28
29
 
# File 'lib/qpush/server/config.rb', line 27

def delay_threads
  @delay_threads
end

#namespace ⇒ Object

Returns the value of attribute namespace.



27
28
29
 
# File 'lib/qpush/server/config.rb', line 27

def namespace
  @namespace
end

#perform_threads ⇒ Object

Returns the value of attribute perform_threads.



27
28
29
 
# File 'lib/qpush/server/config.rb', line 27

def perform_threads
  @perform_threads
end

#priorities ⇒ Object

Returns the value of attribute priorities.



27
28
29
 
# File 'lib/qpush/server/config.rb', line 27

def priorities
  @priorities
end

#queue_threads ⇒ Object

Returns the value of attribute queue_threads.



27
28
29
 
# File 'lib/qpush/server/config.rb', line 27

def queue_threads
  @queue_threads
end

Instance Method Details

#for_keys ⇒ Object 



35
36
37
 
# File 'lib/qpush/server/config.rb', line 35

def for_keys
  { namespace: @namespace, priorities: @priorities }
end