lib/mq/rpc.rb in amqp-0.6.0 vs lib/mq/rpc.rb in amqp-0.6.4

@@ -52,12 +52,14 @@
                  (::Class.new do include(obj) end).new
                else
                  obj
                end
         
-        @mq.queue(queue).subscribe{ |info, request|
+        @mq.queue(queue).subscribe(:ack=>true){ |info, request|
           method, *args = ::Marshal.load(request)
           ret = @obj.__send__(method, *args)
+
+          info.ack
 
           if info.reply_to
             @mq.queue(info.reply_to).publish(::Marshal.dump(ret), :key => info.reply_to, :message_id => info.message_id)
           end
         }
\ No newline at end of file