class RabbitmqClient::Exchange

ExchangeRegistry is a store for all managed exchanges and their details

Attributes

name[R]
options[R]
type[R]

Public Class Methods

new(name, type, options) click to toggle source
# File lib/rabbitmq_client/exchange.rb, line 8
def initialize(name, type, options)
  @name = name
  @type = type
  @options = options
end

Public Instance Methods

create(channel) click to toggle source
# File lib/rabbitmq_client/exchange.rb, line 14
def create(channel)
  exhange_obj = Bunny::Exchange.new(channel, @type, @name,
                                    @options)
  ActiveSupport::Notifications.instrument(
    'created_exhange.rabbitmq_client',
    name: @name,
    type: @type
  )
  exhange_obj
end