Sha256: eb967871fc9e8c5a8f83a4f93e7cfb5030b63a4a24186b4c444453b5bf3bc74c
Contents?: true
Size: 1.11 KB
Versions: 32
Compression:
Stored size: 1.11 KB
Contents
# encoding: utf-8 require 'spec_helper' require 'integration/eventmachine/spec_helper' describe AMQ::Client::EventMachineClient, "Basic.Ack" do include EventedSpec::SpecHelper default_timeout 4 context "sending 100 messages" do let(:messages) { (0..99).map {|i| "Message #{i}" } } it "should receive all the messages" do @received_messages = [] em_amqp_connect do |client| channel = AMQ::Client::Channel.new(client, 1) channel.open do queue = AMQ::Client::Queue.new(client, channel).declare(false, false, false, true) queue.bind("amq.fanout") queue.consume do |amq_method| queue.on_delivery do |method, header, payload| queue.acknowledge(method.delivery_tag) @received_messages << payload end exchange = AMQ::Client::Exchange.new(client, channel, "amq.fanout", :fanout) messages.each do |message| exchange.publish(message) end end done(3.5) { @received_messages =~ messages } end end end end end
Version data entries
32 entries across 32 versions & 1 rubygems