class QPush::Server::WorkerConfig

Constants

DEFAULTS

Attributes

delay_threads[RW]
namespace[RW]
perform_threads[RW]
priorities[RW]
queue_threads[RW]

Public Class Methods

new(options = {}) click to toggle source
# File lib/qpush/server/worker.rb, line 125
def initialize(options = {})
  options = DEFAULTS.merge(options)
  options.each { |key, value| send("#{key}=", value) }
end

Public Instance Methods

validate!() click to toggle source
# File lib/qpush/server/worker.rb, line 130
def validate!
  return if valid?
  fail ServerError, errors.full_messages.join(' ')
end