Contents

require "spec_helper"

describe Bunny::Session do
  let(:http_client) { RabbitMQ::HTTP::Client.new("http://127.0.0.1:15672") }

  def close_connection(client_port)
    c = http_client.
      list_connections.
      find   { |conn_info| conn_info && conn_info.peer_port.to_i == client_port }

    http_client.close_connection(c.name) if c
  end

  def wait_for_recovery
    sleep 0.5
  end

  it "can be closed" do
    c  = Bunny.new(automatically_recover: false)
    c.start
    ch = c.create_channel

    expect(c).to be_connected
    c.stop
    expect(c).to be_closed
  end

  it "can be closed twice (Session#close is idempotent)" do
    c  = Bunny.new(automatically_recover: false)
    c.start
    ch = c.create_channel

    expect(c).to be_connected
    c.stop
    expect(c).to be_closed
    c.stop
    expect(c).to be_closed
  end

  describe "in a single threaded mode" do
    it "can be closed" do
      c  = Bunny.new(automatically_recover: false, threaded: false)
      c.start
      ch = c.create_channel

      expect(c).to be_connected
      c.stop
      expect(c).to be_closed
    end
  end


  describe "that recovers from connection.close" do
    it "can be closed" do
      c  = Bunny.new(automatically_recover: true,
        recover_from_connection_close: true,
        network_recovery_interval: 0.2)
      c.start
      ch = c.create_channel

      expect(c).to be_open
      sleep 1.5
      close_connection(c.local_port)

      wait_for_recovery
      expect(c).to be_open
      expect(ch).to be_open

      c.close
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
bunny-2.6.4	spec/higher_level_api/integration/connection_stop_spec.rb