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

Version Path
amq-client-1.0.4 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-1.0.3 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-1.1.0.pre1 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-1.0.2 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-1.0.1 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-1.0.0 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.12 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.11 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.10 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.9 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.8 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.7 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.6 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.5 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.4 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-1.0.0.pre2 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.3 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-1.0.0.pre1 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.2 spec/integration/eventmachine/basic_ack_spec.rb
amq-client-0.9.1 spec/integration/eventmachine/basic_ack_spec.rb