|
@@ -207,7 +207,7 @@ if __name__ == "__main__":
|
|
|
scheduler_logger = logging.getLogger('apscheduler')
|
|
|
scheduler_logger.setLevel(logging.WARNING)
|
|
|
|
|
|
- use_aliyun_mq = config['use_aliyun_mq']
|
|
|
+ use_aliyun_mq = config['debug_flags']['use_aliyun_mq']
|
|
|
|
|
|
# 初始化不同队列的后端
|
|
|
if use_aliyun_mq:
|
|
@@ -276,7 +276,7 @@ if __name__ == "__main__":
|
|
|
continue
|
|
|
message_id += 1
|
|
|
message = Message.build(MessageType.TEXT, MessageChannel.CORP_WECHAT,
|
|
|
- '7881302581935903','1688854492669990', text, int(time.time() * 1000)
|
|
|
+ '7881301263964433','1688854492669990', text, int(time.time() * 1000)
|
|
|
)
|
|
|
message.msgId = message_id
|
|
|
receive_queue.produce(message)
|