Class: Tochtli::BaseClient

Inherits:
Object
  • Object
show all
Defined in:
lib/tochtli/base_client.rb

Defined Under Namespace

Classes: AbstractMessageHandler, InternalServiceError, MessageHandler, SyncMessageHandler

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(rabbit_client_or_connection = nil, logger = nil) ⇒ BaseClient

Returns a new instance of BaseClient.



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
# 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

Instance Attribute Details

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



3
4
5
 
# File 'lib/tochtli/base_client.rb', line 3

def logger
  @logger
end

#rabbit_client ⇒ Object (readonly)

Returns the value of attribute rabbit_client.



3
4
5
 
# File 'lib/tochtli/base_client.rb', line 3

def rabbit_client
  @rabbit_client
end

#rabbit_connection ⇒ Object (readonly)

Returns the value of attribute rabbit_connection.



3
4
5
 
# File 'lib/tochtli/base_client.rb', line 3

def rabbit_connection
  @rabbit_connection
end

Instance Method Details

#publish(*args) ⇒ Object 



22
23
24
 
# File 'lib/tochtli/base_client.rb', line 22

def publish(*args)
  rabbit_client.publish(*args)
end

#wait_for_confirms ⇒ Object 



26
27
28
 
# File 'lib/tochtli/base_client.rb', line 26

def wait_for_confirms
  rabbit_client.wait_for_confirms
end