Module: MessageBusClientWorker

Includes:
GemConfig::Base
Defined in:
lib/message_bus_client_worker.rb,
lib/message_bus_client_worker/version.rb,
lib/message_bus_client_worker/services/poll.rb,
lib/message_bus_client_worker/workers/enqueuing_worker.rb,
lib/message_bus_client_worker/workers/subscription_worker.rb,
lib/message_bus_client_worker/services/polling/get_last_id.rb,
lib/message_bus_client_worker/services/polling/set_last_id.rb,
lib/message_bus_client_worker/services/polling/generate_uri.rb,
lib/message_bus_client_worker/services/polling/get_payloads.rb,
lib/message_bus_client_worker/services/polling/gen_last_id_key.rb,
lib/message_bus_client_worker/services/polling/generate_params.rb,
lib/message_bus_client_worker/services/polling/process_payload.rb,
lib/message_bus_client_worker/services/polling/generate_client_id.rb

Defined Under Namespace

Modules: Polling Classes: EnqueuingWorker, Poll, SubscriptionWorker

Constant Summary collapse

VERSION = 
"2.1.0"

Class Method Summary collapse

Class Method Details

.subscribe(host, options) ⇒ Object 



33
34
35
36
37
38
39
40
41
 
# File 'lib/message_bus_client_worker.rb', line 33

def self.subscribe(host, options)
  self.configuration.subscriptions ||= {}

  if self.configuration.subscriptions.keys.include?(host)
    warn "[#{self.name}] #{host} already configured, overwriting (called from #{caller.first})"
  end

  self.configuration.subscriptions[host] = options
end