queue_bind_spec.rb

RSpec.describe "A queue" do

  #
  # Environment
  #

  let(:connection) { MarchHare.connect }

  after :each do
    connection.close
  end


  #
  # Examples
  #

  it "can be bound to amq.fanout" do
    ch = connection.create_channel
    x  = ch.exchange("amq.fanout", :type => :fanout, :durable => true, :auto_delete => false)
    q  = ch.queue("", :exclusive => true)
    x.publish("")
    expect(q.get).to eq(nil)

    q.bind(x)

    x.publish("", :routing_key => q.name)
    expect(q.get).not_to eq(nil)


  end


  it "can be bound to a newly declared exchange [an HB::Exchange instance]" do
    ch = connection.create_channel
    x  = ch.exchange("march.hare.fanout", :type => :fanout, :durable => false, :auto_delete => true)
    q  = ch.queue("", :exclusive => true)
    x.publish("")
    expect(q.get).to eq(nil)

    q.bind(x)

    x.publish("", :routing_key => q.name)
    expect(q.get).not_to eq(nil)

    q.unbind(x)
  end

  it "can be bound to a newly declared exchange [a string]" do
    ch = connection.create_channel
    x  = ch.exchange("march.hare.fanout", :type => :fanout, :durable => false, :auto_delete => true)
    q  = ch.queue("", :exclusive => true)
    x.publish("")
    expect(q.get).to eq(nil)

    q.bind("march.hare.fanout")

    x.publish("", :routing_key => q.name)
    expect(q.get).not_to eq(nil)

    q.unbind("march.hare.fanout")
  end


  it "is automatically bound to the default exchange" do
    ch = connection.create_channel
    x  = ch.default_exchange
    q  = ch.queue("", :exclusive => true)

    x.publish("", :routing_key => q.name)
    expect(q.get).not_to eq(nil)
  end

  context "when the exchange does not exist" do
    it "raises an exception" do
      ch = connection.create_channel
      q  = ch.queue("", :exclusive => true)

      raised = nil
      begin
        q.bind("asyd8a9d98sa73t78hd9as^&&(&@#(*^")
      rescue MarchHare::NotFound => e
        raised = e
      end

      expect(raised.channel_close.reply_text).to be =~ /no exchange/
    end
  end
end