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