Class: MessageBusClientWorker::SubscriptionWorker

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

Instance Method Summary collapse

Instance Method Details

#perform(host, subscriptions_json, long = false) ⇒ Object 



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

def perform(host, subscriptions_json, long = false)
  subscriptions = JSON.parse(subscriptions_json).with_indifferent_access

  log(host, subscriptions)
  Poll.call(host, subscriptions, long)
end