1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
require "spec_helper"
require_relative "../../toxiproxy_helper"
if ::Toxiproxy.running?
describe Bunny::Channel, "#basic_publish" do
include RabbitMQ::Toxiproxy
after :each do
@connection.close if @connection.open?
end
context "when the the connection detects missed heartbeats with automatic recovery" do
before(:each) do
setup_toxiproxy
@connection = Bunny.new(user: "bunny_gem", password: "bunny_password", vhost: "bunny_testbed",
host: "localhost:11111", heartbeat_timeout: 1, automatically_recover: true)
@connection.start
end
let(:queue_name) { "bunny.basic.publish.queue#{rand}" }
it "raises a ConnectionClosedError" do
ch = @connection.create_channel
rabbitmq_toxiproxy.down do
sleep 2
expect { ch.default_exchange.publish("", :routing_key => queue_name) }.to raise_error(Bunny::ConnectionClosedError)
end
end
end
context "when the the connection detects missed heartbeats without automatic recovery" do
before(:each) do
setup_toxiproxy
@connection = Bunny.new(user: "bunny_gem", password: "bunny_password", vhost: "bunny_testbed",
host: "localhost:11111", heartbeat_timeout: 1, automatically_recover: false, threaded: false)
@connection.start
end
it "does not raise an exception on session thread" do
rabbitmq_toxiproxy.down do
sleep 5
end
end
end
context "recovery attempt limit that's exceeded" do
let(:dummy) { double(call: true) }
before(:each) do
setup_toxiproxy
@connection = Bunny.new(user: "bunny_gem", password: "bunny_password", vhost: "bunny_testbed",
host: "localhost:11111", heartbeat_timeout: 1, automatically_recover: true, network_recovery_interval: 1,
recovery_attempts: 2, recovery_attempts_exhausted: Proc.new { dummy.call }, reset_recovery_attempts_after_reconnection: true,
disconnect_timeout: 1)
@connection.start
end
it "permanently closes connection" do
expect(@connection.open?).to be(true)
rabbitmq_toxiproxy.down do
sleep 5
end
# give the connection one last chance to recover
sleep 3
expect(@connection.open?).to be(false)
expect(@connection.closed?).to be(true)
expect(dummy).to have_received(:call).once
end
end # context
end # describe
else
puts "Toxiproxy isn't running, some examples will be skipped"
end
|
