examples/patterns/request_reply/server.rb in amqp-0.9.10 vs examples/patterns/request_reply/server.rb in amqp-1.0.0.pre1

@@ -12,9 +12,10 @@
   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