Permalink
Browse files

Don't use :immediate flag in examples since it will not unsupported i…

…n RabbitMQ 2.9 [ci skip]
  • Loading branch information...
1 parent 8dbf8c7 commit d642f8fb9f2457b65e08a3efb544c6984333ad06 @michaelklishin michaelklishin committed Oct 2, 2012
@@ -39,7 +39,7 @@
EventMachine.add_periodic_timer(0.8) do
puts "Publishing via amq.fanout..."
# messages must be routable & there must be at least one consumer.
- exchange.publish("Routed via amq.fanout", :immediate => true, :mandatory => true)
+ exchange.publish("Routed via amq.fanout", :mandatory => true)
end
@@ -19,8 +19,7 @@
channel.default_exchange.publish("get.time",
:routing_key => "amqpgem.examples.services.time",
:message_id => Kernel.rand(10101010).to_s,
- :reply_to => replies_queue.name,
- :immediate => true)
+ :reply_to => replies_queue.name)
end
@@ -14,7 +14,6 @@
channel.default_exchange.publish(Time.now.to_s,
:routing_key => metadata.reply_to,
:correlation_id => metadata.message_id,
- :immediate => true,
:mandatory => true)
metadata.ack
@@ -22,7 +22,7 @@
EventMachine.add_timer(0.3) {
10.times do |i|
- exchange.publish("Message ##{i}", :immediate => true)
+ exchange.publish("Message ##{i}")
end
}

0 comments on commit d642f8f

Please sign in to comment.