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
76
77
78
79
80
81
82
83
84
85
86
87
|
# encoding: utf-8
require 'spec_helper'
require 'amqp'
describe AMQP do
#
# Examples
#
it "has default settings" do
s = AMQP.settings.dup
s[:host].should == "127.0.0.1"
s[:port].should == 5672
s[:user].should == "guest"
s[:pass].should == "guest"
s[:heartbeat].should be_nil
s[:auth_mechanism].should eq([])
end
describe "connection to RabbitMQ with a connection string" do
include EventedSpec::SpecHelper
em_before { AMQP.cleanup_state }
em_after { AMQP.cleanup_state }
it 'parses URI string' do
em do
AMQP.start("amqp://guest:guest@127.0.0.1?heartbeat=10&connection_timeout=100") do |session|
expect(session.heartbeat_interval).to eq(10)
expect(session.connection_timeout).to eq(100)
session.close
end
done(0.3)
end
end
end
describe '.start' do
#
# Environment
#
include EventedSpec::SpecHelper
em_before { AMQP.cleanup_state }
em_after { AMQP.cleanup_state }
#
# Examples
#
it 'yields to given block AFTER connection is established' do
em do
AMQP.start AMQP_OPTS do
@block_fired = true
AMQP.connection.should be_connected
end
done(0.3) { @block_fired.should be_true }
end
end
it 'should try to connect again in case previous conection failed' do
em do
timeout(20)
error_handler = proc { EM.next_tick { AMQP.start(AMQP_OPTS) { done } } }
# Assuming that you don't run your amqp @ port 65535
AMQP.start(AMQP_OPTS.merge(:port => 65535, :on_tcp_connection_failure => error_handler))
end
end
it 'should keep connection if there was no failure' do
em do
error_handler = proc {}
@block_fired_times = 0
AMQP.start(AMQP_OPTS) { @block_fired_times += 1 }
delayed(0.1) { AMQP.start(AMQP_OPTS) { @block_fired_times += 1 } }
done(0.3) { @block_fired_times.should == 1 }
end
end
end # .start
end # describe AMQP
|
