Make queue processing transactional