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
|
# encoding: utf-8
require 'spec_helper'
describe AMQP do
#
# Environment
#
include EventedSpec::AMQPSpec
default_timeout 5
#
# Examples
#
context "when queue is redeclared with different attributes across two channels" do
let(:name) { "amqp-gem.nondurable.queue" }
let(:options) {
{ :durable => false, :passive => false }
}
let(:different_options) {
{ :durable => true, :passive => false }
}
it "should trigger channel-level #on_error callback" do
@channel = AMQP::Channel.new
@channel.on_error do |ch, close|
puts "This should never happen"
end
@q1 = @channel.queue(name, options)
# Small delays to ensure the order of execution
delayed(0.1) {
@other_channel = AMQP::Channel.new
@other_channel.on_error do |ch, close|
@callback_fired = true
end
puts "other_channel.id = #{@other_channel.id}"
@q2 = @other_channel.queue(name, different_options)
}
delayed(0.3) {
@q2.delete
}
done(0.4) {
@callback_fired.should be_true
# looks like there is a difference between platforms/machines
# so check either one. MK.
@other_channel.closed?.should be_true
}
end
end
end # describe AMQP
|
