4dkankan-center-modeling/src/main/java/com/fdkankan/modeling/receiver/QueueNameService.java

package com.fdkankan.modeling.receiver;

import cn.hutool.core.io.FileUtil;
import cn.hutool.core.util.StrUtil;
import com.fdkankan.modeling.constants.RabbitMQConstant;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Service
@Slf4j
public class QueueNameService {

    public String getInterruptCallingQueueName(){
        String queueName = FileUtil.readUtf8String("/opt/queue-name-interrupt-calling.txt");
        if(StrUtil.isEmpty(queueName)){
            queueName = RabbitMQConstant.QUEUE_FANOUT;
        }
        return queueName;
    }
}