In DeleteQueue, we only rollback after the first select fails (which shouldn't be needed) and we are missing rollbacks after failures post DELETE statements.
I am adding a defer to rollback which should be a no-op if the commit went through. This is already done in Enqueue.
In
DeleteQueue
, we only rollback after the first select fails (which shouldn't be needed) and we are missing rollbacks after failures post DELETE statements.I am adding a defer to rollback which should be a no-op if the commit went through. This is already done in
Enqueue
.