gcp-ingestion
gcp-ingestion copied to clipboard
Add test for flushing a queue with outstanding in-flight messages
- create a queue with a disk location
- write a message to the queue
- call
get
to make the message in-flight- don't ack or nack the message
- attempt to flush the queue from scratch
-
don't reuse or
del
the existing queue object
-
don't reuse or
- assert that the message was delivered
This should catch regressions of https://github.com/peter-wangxu/persist-queue/pull/154