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
|
# encoding: utf-8
require 'spec_helper'
unless ENV["CI"]
describe "Per-channel automatic channel recovery" do
#
# Environment
#
include RabbitMQ::Control
include EventedSpec::AMQPSpec
default_timeout 20.0
amqp_before do
@channel = AMQP::Channel.new(AMQP.connection, :auto_recovery => true)
end
after :all do
start_rabbitmq unless rabbitmq_pid
end
# ...
#
# Examples
#
it "kicks in when broker goes down" do
AMQP.connection.on_tcp_connection_loss do |conn, settings|
puts "[network failure] Trying to reconnect..."
conn.reconnect(false, 1)
end
pid = rabbitmq_pid
puts "rabbitmq pid = #{pid.inspect}"
kill_rabbitmq
rabbitmq_pid.should be_nil
# 2 seconds later, check that we are reconnecting
EventMachine.add_timer(2.0) do
AMQP.connection.should_not be_connected
AMQP.connection.should be_reconnecting
end
# 4 seconds later, start RabbitMQ
EventMachine.add_timer(4.0) do
start_rabbitmq
rabbitmq_pid.should_not be_nil
end
# 12 seconds later, use the (now recovered) connection. Note that depending
# on # of plugins used it may take 5-10 seconds to start up RabbitMQ and initialize it,
# then open a new AMQP connection. That's why we wait. MK.
EventMachine.add_timer(12.0) do
AMQP.connection.should be_connected
AMQP.connection.should_not be_reconnecting
@channel.queue("amqpgem.tests.a.queue", :auto_delete => true).subscribe do |metadata, payload|
puts "Got a message"
done
end
EventMachine.add_timer(1.5) { @channel.default_exchange.publish("Hi", :routing_key => "amqpgem.tests.a.queue") }
end
end
end
end
|
