Sha256: d573f3bdaf51d6f4d9f12f8e90247aea08539f2c6f17d018e709e5e958df4685
Contents?: true
Size: 915 Bytes
Versions: 12
Compression:
Stored size: 915 Bytes
Contents
# -*- coding: utf-8 -*-
require "spec_helper"
describe "Message published as mandatory" do
#
# Environment
#
include EventedSpec::AMQPSpec
include EventedSpec::SpecHelper
em_before { AMQP.cleanup_state }
em_after { AMQP.cleanup_state }
default_options AMQP_OPTS
default_timeout 3
amqp_before do
@channel = AMQP::Channel.new
@channel.should be_open
@exchange = @channel.fanout
end
after(:all) do
AMQP.cleanup_state
done
end
context "that cannot be routed to any queue" do
it "is returned to the publisher via basic.return" do
returned_messages = []
@exchange.on_return do |basic_return|
returned_messages << basic_return.reply_text
end
(1..10).to_a.each { |m| @exchange.publish(m, :immediate => true) }
done(1.0) {
returned_messages.should == Array.new(10) { "NO_CONSUMERS" }
}
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems