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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
# encoding: utf-8
require 'spec_helper'
describe AMQP::Channel do
#
# Environment
#
include EventedSpec::AMQPSpec
default_options AMQP_OPTS
default_timeout 2
amqp_before do
@channel = AMQP::Channel.new
end
#
# Examples
#
describe "exchange to exchange bindings" do
context "basic properties" do
it "bind returns self" do
source1 = @channel.fanout("fanout-exchange-source-1")
source2 = @channel.fanout("fanout-exchange-source-2")
destination = @channel.fanout("fanout-exchange-destination-multi")
destination.bind(source1).bind(source2).should == destination
done
end
it "bind can work with strings for source exchange parameter" do
@channel.fanout("fanout-exchange-source-3")
destination = @channel.fanout("fanout-exchange-destination-multi-2")
destination.bind('fanout-exchange-source-3').should == destination
done
end
end
context "fanout exchanges" do
it "are bindable and forward messages" do
source = @channel.fanout("fanout-exchange-source")
destination = @channel.fanout("fanout-exchange-destination")
messages = []
destination.bind(source) do
queue = @channel.queue("fanout-forwarding", :auto_delete => true)
queue.subscribe do |metadata, payload|
messages << payload
end
queue.bind(destination) do
source.publish("x")
end
end
done(0.5) { messages.should == ["x"] }
end
it "can be unbound" do
source = @channel.fanout("fanout-exchange-source-2")
destination = @channel.fanout("fanout-exchange-destination-2")
destination.bind(source) do
destination.unbind(source) do
done
end
end
end
it "can be unbound without callbacks" do
source = @channel.fanout("fanout-exchange-source-2")
destination = @channel.fanout("fanout-exchange-destination-2")
destination.bind(source)
destination.unbind(source)
done
end
it "using :nowait => true should not call a passed in block" do
source = @channel.fanout("fanout-exchange-source-no-wait")
destination = @channel.fanout("fanout-exchange-destination-no-wait")
callback_called = false
destination.bind(source, :nowait => true) do
callback_called = true
end
done(0.5) { callback_called.should be_false}
end
end #context
context "topic exchanges" do
it "using routing key '#'" do
source = @channel.topic("topic-exchange-source")
destination = @channel.topic("topic-exchange-destination")
messages = []
destination.bind(source, :routing_key => "#") do
queue = @channel.queue("ex-to-ex-default-key", :auto_delete => true)
queue.bind(destination, :routing_key => "#").subscribe do |metadata, payload|
messages << payload
end
source.publish("a", :routing_key => "lalalala")
end
done(0.5) { messages.should == ["a"] }
end
it "using routing key 'foo'" do
source = @channel.topic("topic-exchange-source-foo")
destination = @channel.topic("topic-exchange-destination-foo")
messages = []
destination.bind(source, :routing_key => 'foo') do
queue = @channel.queue("foo-foo", :auto_delete => true)
queue.subscribe do |metadata, payload|
messages << payload
end
queue.bind(destination, :routing_key => "foo") do
source.publish("b", :routing_key => "foo")
end
end
done(0.5) { messages.should == ["b"]}
end
end #context
end # describe
end # describe AMQP
|
