module RabbitmqClient

RabbitmqClient Module is used as a clinet library for Rabbitmq This Module is supporting the following use cases

Publish events to Rabbitmq server

Constants

VERSION

Public Class Methods

add_exchange(name, type, options = {}) click to toggle source

# File lib/rabbitmq_client.rb, line 70
def add_exchange(name, type, options = {})
  @exchange_registry.add(name, type, options)
end

lifecycle() click to toggle source

# File lib/rabbitmq_client.rb, line 78
def lifecycle
  @lifecycle ||= setup_lifecycle
end

logger() click to toggle source

# File lib/rabbitmq_client.rb, line 82
def logger
  @logger ||= setup_logger
end

publish(payload, options = {}) click to toggle source

# File lib/rabbitmq_client.rb, line 74
def publish(payload, options = {})
  publisher.publish(payload, options)
end

Private Class Methods

init_publisher() click to toggle source

# File lib/rabbitmq_client.rb, line 96
def init_publisher
  Publisher.new(config.merge(
                  exchange_registry: @exchange_registry
                ))
end

publisher() click to toggle source

# File lib/rabbitmq_client.rb, line 92
def publisher
  @publisher ||= init_publisher
end

setup_lifecycle() click to toggle source

# File lib/rabbitmq_client.rb, line 102
def setup_lifecycle
  @lifecycle = Lifecycle.new
  plugins.each(&:new)
  @lifecycle
end

setup_logger() click to toggle source

# File lib/rabbitmq_client.rb, line 88
def setup_logger
  LoggerBuilder.new(config[:logger_configs]).build_logger
end