Fixes a ghost messages issue where the queue cursor goes out of sync /w the leveldb store when transactions are being used.