lib/bbk/amqp/utils.rb in bbk-amqp-1.0.0.105775 vs lib/bbk/amqp/utils.rb in bbk-amqp-1.0.0.109994

@@ -42,14 +42,15 @@
           sleep timeout
           unblocker << :timeout
         end
         result = unblocker.pop
         if result == :timeout
+          consumed = true
           consumer.cancel
           raise ::Timeout::Error
         end
         queue.channel.ack(result[0].delivery_tag)
-        sleep 0.1
+        sleep 0.2
         consumer.cancel
         result
       end
 
       # Extract CN certificate attribute from certificate path