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