class Freddy::Adapters::MarchHareAdapter::Channel

Constants

NO_ROUTE

Public Class Methods

new(channel) click to toggle source
# File lib/freddy/adapters/march_hare_adapter.rb, line 30
def initialize(channel)
  @channel = channel
end

Public Instance Methods

on_no_route(&block) click to toggle source
# File lib/freddy/adapters/march_hare_adapter.rb, line 40
def on_no_route(&block)
  @channel.on_return do |reply_code, _, exchange_name, _, properties|
    if exchange_name != Freddy::FREDDY_TOPIC_EXCHANGE_NAME && reply_code == NO_ROUTE
      block.call(properties.correlation_id)
    end
  end
end
queue(*args) click to toggle source
# File lib/freddy/adapters/march_hare_adapter.rb, line 36
def queue(*args)
  Queue.new(@channel.queue(*args))
end