lib/fake_sqs/queues.rb in fake_sqs-0.0.11 vs lib/fake_sqs/queues.rb in fake_sqs-0.1.0

- old
+ new

@@ -58,9 +58,15 @@ def reset database.reset end + def timeout_messages! + transaction do + database.each { |name,queue| queue.timeout_messages! } + end + end + def expire transaction do database.each { |name, queue| queue.expire } end end