class Discobolo::Supervisor

Public Class Methods

concurrency() click to toggle source
# File lib/discobolo/supervisor.rb, line 14
def self.concurrency
  Discobolo::Config.actor_concurrency
end

Public Instance Methods

register_queues() click to toggle source
# File lib/discobolo/supervisor.rb, line 5
def register_queues
  self.pool Discobolo::Actor, size: self.class.concurrency,
                              as: :discobolo_pool,
                              args: { fetch: true } 

  Discobolo::Config.logger.info "#{self.actors.size} registered actors"
  self
end