Method: Messaging::ConsumerSupervisor#initialize

Defined in:
lib/messaging/consumer_supervisor.rb

#initialize ⇒ ConsumerSupervisor

Returns a new instance of ConsumerSupervisor.



6
7
8
9
 
# File 'lib/messaging/consumer_supervisor.rb', line 6

def initialize
  @threads = Concurrent::Array.new
  Messaging.routes.define_consumers!
end