Sha256: a7c67106c936a76e190fe27869b8af091b5f46febaf455e2b3eeb969c5841f04
Contents?: true
Size: 1.54 KB
Versions: 8
Compression:
Stored size: 1.54 KB
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.peer_port.to_i == client_port }
http_client.close_connection(c.name)
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
close_connection(c.local_port)
sleep 0.2
expect(c).not_to be_open
wait_for_recovery
expect(c).to be_open
expect(ch).to be_open
c.close
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems