Refactor to use Magento native functionality for DB queue adapter