ic-ctbu-backend/plugin/mq/jkesMqNames.js

/**
 * 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')
}