fdkankan-mq-controller/src/main/java/com/fdkankan/mqcontroller/task/RabbitMqService.java

package com.fdkankan.mqcontroller.task;

import com.fdkankan.mqcontroller.entity.MqMsg;
import com.fdkankan.mqcontroller.entity.MqQueueConfig;
import com.fdkankan.mqcontroller.utils.RabbitMqUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.List;

@Service
public class RabbitMqService {

    @Value("${spring.rabbitmq.host}")
    public String host;
    @Value("${spring.rabbitmq.username}")
    public String username;
    @Value("${spring.rabbitmq.password}")
    public String password;
    @Value("${spring.rabbitmq.virtual-host}")
    public String virtualHost;
    @Value("${spring.rabbitmq.mgmt-url}")
    public String mgmtUrl;
    @Value("${spring.rabbitmq.mgmt-host}")
    public String mgmtHost;

    public MqMsg getRabbitMqMsg(String queueName) {
        return RabbitMqUtils.getRabbitMqMsg(mgmtUrl+host+":"+mgmtHost,virtualHost,username,password,queueName);
    }


    public  void getMqMsgMap(List<MqQueueConfig> queueConfigList) {
        for (MqQueueConfig mqQueueConfig : queueConfigList) {
            MqMsg mqMsg = getRabbitMqMsg(mqQueueConfig.getQueueName());
            TaskService.mqMsgMap.put(mqQueueConfig.getQueueName(),mqMsg);
        }
    }
}