Sha256: a23afcee1c339e5c93a2ee2ec5e305e77a71a85b4010cb2aa487d444c022b8d1
Contents?: true
Size: 1.67 KB
Versions: 28
Compression:
Stored size: 1.67 KB
Contents
# encoding: utf-8
require 'spec_helper'
describe "Large messages that need to be framed" do
#
# Environment
#
include EventedSpec::AMQPSpec
default_timeout 10
amqp_before do
@channel = AMQP::Channel.new
@channel.should be_open
@channel.on_error do |ch, close|
raise "Channel-level error!: #{close.inspect}"
end
@queue1 = @channel.queue("amqpgem.tests.integration.queue#{Time.now.to_i}#{rand}", :exclusive => true)
@queue2 = @channel.queue("amqpgem.tests.integration.queue#{Time.now.to_i}#{rand}", :exclusive => true)
# Rely on default direct exchange binding, see section 2.1.2.4 Automatic Mode in AMQP 0.9.1 spec.
@exchange = AMQP::Exchange.default(@channel)
end
default_options AMQP_OPTS
let(:body) { "мультибайт" * 1024 * 1024 }
#
# Examples
#
it "are framed correctly" do
@exchange.channel.should == @channel
number_of_received_messages = 0
expected_number_of_messages = 3
dispatched_data = "to be received by queue1"
@queue1.subscribe do |payload|
number_of_received_messages += 1
payload.should == dispatched_data
end # subscribe
4.times do
@exchange.publish(body, :routing_key => "killa key")
end
expected_number_of_messages.times do
@exchange.publish(dispatched_data, :routing_key => @queue1.name)
end
4.times do
@exchange.publish(body, :routing_key => "killa key")
end
delayed(0.6) {
# We never subscribe to it, hence, need to delete manually
@queue2.delete
}
done(5.0) {
number_of_received_messages.should == expected_number_of_messages
}
end # it
end # describe
Version data entries
28 entries across 28 versions & 1 rubygems