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