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.



24
25
26
27
 
# File 'lib/qpush/server/config.rb', line 24

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.



21
22
23
 
# File 'lib/qpush/server/config.rb', line 21

def delay_threads
  @delay_threads
end

#namespace ⇒ Object

Returns the value of attribute namespace.



21
22
23
 
# File 'lib/qpush/server/config.rb', line 21

def namespace
  @namespace
end

#perform_threads ⇒ Object

Returns the value of attribute perform_threads.



21
22
23
 
# File 'lib/qpush/server/config.rb', line 21

def perform_threads
  @perform_threads
end

#priorities ⇒ Object

Returns the value of attribute priorities.



21
22
23
 
# File 'lib/qpush/server/config.rb', line 21

def priorities
  @priorities
end

#queue_threads ⇒ Object

Returns the value of attribute queue_threads.



21
22
23
 
# File 'lib/qpush/server/config.rb', line 21

def queue_threads
  @queue_threads
end

Instance Method Details

#for_keys ⇒ Object 



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

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