class TopologicalInventory::Providers::Common::MessagingClient

Attributes

queue_host[RW]

Kafka host name

queue_port[RW]

Kafka port

Public Class Methods

configure() { |default| ... } click to toggle source
# File lib/topological_inventory/providers/common/messaging_client.rb, line 23
def self.configure
  if block_given?
    yield(default)
  else
    default
  end
end
default() click to toggle source
# File lib/topological_inventory/providers/common/messaging_client.rb, line 19
def self.default
  @@default ||= new
end
new() click to toggle source
# File lib/topological_inventory/providers/common/messaging_client.rb, line 14
def initialize
  self.queue_host = TopologicalInventory::Providers::Common::ClowderConfig.instance["kafkaHost"]
  self.queue_port = TopologicalInventory::Providers::Common::ClowderConfig.instance["kafkaPort"].to_i
end

Public Instance Methods

client() click to toggle source
# File lib/topological_inventory/providers/common/messaging_client.rb, line 35
def client
  self.class.client
end