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
|
# encoding: utf-8
require "spec_helper"
describe "Exclusive server-named queue" do
#
# Environment
#
include EventedSpec::AMQPSpec
default_timeout 2
amqp_before do
@channel = AMQP::Channel.new
@channel.should be_open
@exchange = AMQP::Exchange.default(@channel)
end
it "can be used for temporary point-to-point communication" do
@exchange.channel.should == @channel
@channel.queue("", :exclusive => true) do |queue1|
puts "First callback has fired"
@channel.queue("", :exclusive => true) do |queue2|
puts "Second callback has fired"
request_timestamp = Time.now.to_i
reply_timestamp = nil
queue1.subscribe do |header, body|
header.timestamp.to_i.should == request_timestamp.to_i
header.app_id.should == "Client"
header.reply_to.should == queue2.name
reply_timestamp = Time.now.to_i
@exchange.publish(rand(1000), :routing_key => header.reply_to, :reply_to => queue1.name, :app_id => "Server", :timestamp => reply_timestamp)
end
queue2.subscribe do |header, body|
header.timestamp.to_i.should == reply_timestamp.to_i
header.app_id.should == "Server"
header.reply_to.should == queue1.name
end
# publish the request
@exchange.publish(rand(1000),
:routing_key => queue1.name,
:reply_to => queue2.name,
:app_id => "Client",
:timestamp => request_timestamp,
:mandatory => true)
done(0.2) {
queue1.unsubscribe
queue2.unsubscribe
}
end # do
end # do
end # it
end # describe
|
