import json

from base.utils import config
from base.utils.log import logger
from base.utils.mq_receiver import get_mq_data, save_mq_err, send_mq_ack, start_mq_consume, callback_test
from base.utils.mq_sender import send_one_mq_data

if __name__ == '__main__':
    QUEUE_NAME = 'aic.aic_deep.to.spider.queue'
    jsonStr = json.dumps({"msg": "test2"})
    send_one_mq_data(QUEUE_NAME, jsonStr, ('dev', config.MQ_URL_DEV))
    # DEMO
    start_mq_consume(QUEUE_NAME, callback_test, ('dev', config.MQ_URL_DEV))  # 只启动指定环境的队列