examples/patterns/request_reply/server.rb in amqp-0.9.7 vs examples/patterns/request_reply/server.rb in amqp-0.9.8
- old
+ new
@@ -12,10 +12,9 @@
requests_queue.subscribe(:ack => true) do |metadata, payload|
puts "[requests] Got a request #{metadata.message_id}. Sending a reply..."
channel.default_exchange.publish(Time.now.to_s,
:routing_key => metadata.reply_to,
:correlation_id => metadata.message_id,
- :immediate => true,
:mandatory => true)
metadata.ack
end