As the example shows, current SqliteQueueDatabase implementation does not implement transactions.
While doing a review it looks like it may be achieved by Thread-Local storage - so for each transaction, a local queue is created, and at the end it's flushed to the writer as a whole.
As the example shows, current
SqliteQueueDatabase
implementation does not implement transactions.While doing a review it looks like it may be achieved by Thread-Local storage - so for each transaction, a local queue is created, and at the end it's flushed to the writer as a whole.