Implement storage-mq-related func