/** * JKES 乐跑侧 RabbitMQ 连接名 / 队列基名(与主分支隔离,支持 rabbitmq.mqPrefix 测试前缀) */ const { mq } = require('./mqPrefix') /** 未加 mqPrefix 的队列基名 */ const QUEUE_BASE_NAMES = [ 'jkes_runforge_task_queue', 'jkes_runforge_task_result_queue', 'jkes_runforge_task_dead_queue', 'jkes_runforge_message_queue', 'jkes_order_payment_check', 'jkes_mq_health_check' ] module.exports = { QUEUE_BASE_NAMES, /** 手动触发乐跑 */ channelLepaoApi: mq('jkes_lepao_api'), /** 定时/补充乐跑 */ channelLepaoCorn: mq('jkes_lepao_corn'), /** 登录后自动投递 */ channelAccountAutorun: mq('jkes_lepao_account_autorun'), /** Redis 延迟调度 tick */ channelScheduleTick: mq('jkes_lepao_schedule_tick'), /** Bot 通知(UpdateAccount JKES) */ queueNotify: mq('jkes_lepao_notify_queue'), RESULT_QUEUE: mq('jkes_runforge_task_result_queue'), DEAD_QUEUE: mq('jkes_runforge_task_dead_queue'), MESSAGE_QUEUE: mq('jkes_runforge_message_queue'), ORDER_PAYMENT_QUEUE: mq('jkes_order_payment_check'), HEALTH_CHECK_QUEUE: mq('jkes_mq_health_check') }