Class: MessageBusClientWorker::EnqueuingWorker

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::Worker
Defined in:
lib/message_bus_client_worker/workers/enqueuing_worker.rb

Instance Method Summary collapse

Instance Method Details

#perform ⇒ Object 



7
8
9
10
11
 
# File 'lib/message_bus_client_worker/workers/enqueuing_worker.rb', line 7

def perform
  MessageBusClientWorker.configuration.subscriptions.each do |host, subs|
    SubscriptionWorker.perform_async(host, subs)
  end
end