Sha256: fc8ae96842a06a5c44629b81f4d45e8410e59ebe3bc7c7d8d51324ef50c32d9b
Contents?: true
Size: 1.48 KB
Versions: 1
Compression:
Stored size: 1.48 KB
Contents
# encoding: utf-8 require 'spec_helper' describe "Queue that was bound to default direct exchange thanks to Automatic Mode (section 2.1.2.4 in AMQP 0.9.1 spec" do # # Environment # include AMQP::Spec default_timeout 10 amqp_before do @channel = MQ.new @queue1 = @channel.queue("queue1") @queue2 = @channel.queue("queue2") # Rely on default direct exchange binding, see section 2.1.2.4 Automatic Mode in AMQP 0.9.1 spec. @exchange = MQ::Exchange.default end # # Examples # it "receives messages with routing key equals it's name" do 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 if number_of_received_messages == expected_number_of_messages $stdout.puts "Got all the messages I expected, wrapping up..." done else n = expected_number_of_messages - number_of_received_messages $stdout.puts "Still waiting for #{n} more message(s)" end end # subscribe 4.times do @exchange.publish("some white noise", :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("some white noise", :routing_key => "killa key") end end # it end # describe
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
amqp-0.7.0 | spec/integration/automatic_binding_for_default_direct_exchange_spec.rb |