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