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

const config = require('../../config.json')

/**
 * 与生产环境共享同一 RabbitMQ 时，可用此前缀隔离“连接侧 channel 缓存名”和真实队列名。
 * 临时测试：在 config.json 的 rabbitmq.mqPrefix 设为 "test_"；恢复生产设为空字符串或删除该字段。
 */
const PREFIX = String((config.rabbitmq && config.rabbitmq.mqPrefix) || '')

function mq(name) {
    if (name == null || name === '') return name
    const s = String(name)
    if (!PREFIX) return s
    if (s.startsWith(PREFIX)) return s
    return PREFIX + s
}

module.exports = { mq, PREFIX }