lib/cloudist/job_queue.rb in cloudist-0.0.2 vs lib/cloudist/job_queue.rb in cloudist-0.0.3

@@ -13,16 +13,16 @@
       super
       @mq.prefetch(self.prefetch)
     end
 
     def subscribe(amqp_opts={}, opts={})
-      amqp_opts[:ack] = true
+      amqp_opts[:ack] ||= true
       super(amqp_opts, opts) do |request|
         begin
           yield request if block_given?
         ensure
           request.ack unless amqp_opts[:auto_ack] == false
         end
       end
     end
   end
-end
\ No newline at end of file
+end