Class: QPush::Server::WorkerConfig

Inherits:
Object
  • Object
show all
Includes:
ObjectValidator::Validate
Defined in:
lib/qpush/server/worker.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.



125
126
127
128
 
# File 'lib/qpush/server/worker.rb', line 125

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.



122
123
124
 
# File 'lib/qpush/server/worker.rb', line 122

def delay_threads
  @delay_threads
end

#namespace ⇒ Object

Returns the value of attribute namespace.



122
123
124
 
# File 'lib/qpush/server/worker.rb', line 122

def namespace
  @namespace
end

#perform_threads ⇒ Object

Returns the value of attribute perform_threads.



122
123
124
 
# File 'lib/qpush/server/worker.rb', line 122

def perform_threads
  @perform_threads
end

#priorities ⇒ Object

Returns the value of attribute priorities.



122
123
124
 
# File 'lib/qpush/server/worker.rb', line 122

def priorities
  @priorities
end

#queue_threads ⇒ Object

Returns the value of attribute queue_threads.



122
123
124
 
# File 'lib/qpush/server/worker.rb', line 122

def queue_threads
  @queue_threads
end

Instance Method Details

#validate! ⇒ Object 



130
131
132
133
 
# File 'lib/qpush/server/worker.rb', line 130

def validate!
  return if valid?
  fail ServerError, errors.full_messages.join(' ')
end