Class: Eventboss::Manager

Inherits:
Object
  • Object
show all
Defined in:
lib/eventboss/manager.rb

Constant Summary collapse

MIN_DISPATCH_INTERVAL = 
0.1

Instance Method Summary collapse

Constructor Details

#initialize(fetcher, polling_strategy, executor, queue_listeners, concurrency, error_handlers) ⇒ Manager

Returns a new instance of Manager.



5
6
7
8
9
10
11
12
13
 
# File 'lib/eventboss/manager.rb', line 5

def initialize(fetcher, polling_strategy, executor, queue_listeners, concurrency, error_handlers)
  @fetcher          = fetcher
  @polling_strategy = polling_strategy
  @max_processors   = concurrency
  @busy_processors  = Concurrent::AtomicFixnum.new(0)
  @executor         = executor
  @queue_listeners  = queue_listeners
  @error_handlers   = Array(error_handlers)
end

Instance Method Details

#start ⇒ Object 



15
16
17
18
19
 
# File 'lib/eventboss/manager.rb', line 15

def start
  Eventboss::Logger.debug('Starting dispatch loop...')

  dispatch_loop
end