class Tochtli::BaseClient
Attributes
logger[R]
rabbit_client[R]
rabbit_connection[R]
Public Class Methods
new(rabbit_client_or_connection = nil, logger = nil)
click to toggle source
# File lib/tochtli/base_client.rb, line 5 def initialize(rabbit_client_or_connection = nil, logger = nil) logger ||= Tochtli.logger case rabbit_client_or_connection when Tochtli::RabbitClient @rabbit_client = rabbit_client_or_connection when Tochtli::RabbitConnection @rabbit_client = Tochtli::RabbitClient.new(rabbit_client_or_connection, logger) when NilClass @rabbit_client = Tochtli::RabbitClient.new(nil, logger) else raise ArgumentError, "Tochtli::RabbitClient or Tochtli::RabbitConnection expected, got: #{rabbit_client_or_connection.class}" end @rabbit_connection = @rabbit_client.rabbit_connection @logger = logger end
Public Instance Methods
publish(*args)
click to toggle source
# File lib/tochtli/base_client.rb, line 22 def publish(*args) rabbit_client.publish(*args) end
wait_for_confirms()
click to toggle source
# File lib/tochtli/base_client.rb, line 26 def wait_for_confirms rabbit_client.wait_for_confirms end