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
|
# encoding: utf-8
require 'spec_helper'
describe "When exchange a message is published to has no bindings" do
#
# Environment
#
include EventedSpec::AMQPSpec
default_timeout 1.5
amqp_before do
@producer_channel = AMQP::Channel.new
@consumer_channel = AMQP::Channel.new
end
# ...
#
# Examples
#
context "and message is published as :mandatory" do
it "that message is returned to the publisher" do
exchange = @producer_channel.fanout("amqpgem.examples.mandatory.messages", :auto_delete => true)
exchange.on_return do |basic_return, metadata, payload|
done if payload == "mandatory message body"
end
exchange.publish "mandatory message body", :mandatory => true
end
end
context "and message is published as non :mandatory" do
it "that message is dropped" do
exchange = @producer_channel.fanout("amqpgem.examples.mandatory.messages", :auto_delete => true)
exchange.on_return do |basic_return, metadata, payload|
fail "Should not happen"
end
exchange.publish "mandatory message body", :mandatory => false
done(1.0)
end
end
end # describe
|
