mq 相关配置去除，启动配置修改

zhongrj

2022-08-18 38d775fa2ccd433c727a5b7cec8bed02493df1ec

 src/main/java/org/springblade/modules/rabbitmq/config/MQsender.java

@@ -1,37 +1,37 @@
package org.springblade.modules.rabbitmq.config;

import org.springblade.modules.rabbitmq.redis.RedisService;
import org.springblade.modules.rabbitmq.vo.TaskMessage;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * 消息发送
 * @author zhongrj
 * @since 2022-04-12
 *
 */
@Service
public class MQsender {

    @Autowired
    AmqpTemplate amqpTemplate;


    public void send(Object message){
        String msg = RedisService.beanToString(message);
        amqpTemplate.convertAndSend(MQConfig.QUEUE,msg);
    }

   public void sendTaskMessage(TaskMessage message){
      String msg = RedisService.beanToString(message);
      amqpTemplate.convertAndSend(MQConfig.TASK_QUEUE,msg);
   }

    public void sendTopic(Object message){
        String msg = RedisService.beanToString(message);
        amqpTemplate.convertAndSend(MQConfig.TOPIC_EXCHANGE,"topic.key1",msg+"1");
    }

}
//package org.springblade.modules.rabbitmq.config;
//
//import org.springblade.modules.rabbitmq.redis.RedisService;
//import org.springblade.modules.rabbitmq.vo.TaskMessage;
//import org.springframework.amqp.core.AmqpTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//
///**
// * 消息发送
// * @author zhongrj
// * @since 2022-04-12
// *
// */
//@Service
//public class MQsender {
//
//    @Autowired
//    AmqpTemplate amqpTemplate;
//
//
//    public void send(Object message){
//        String msg = RedisService.beanToString(message);
//        amqpTemplate.convertAndSend(MQConfig.QUEUE,msg);
//    }
//
//   public void sendTaskMessage(TaskMessage message){
//      String msg = RedisService.beanToString(message);
//      amqpTemplate.convertAndSend(MQConfig.TASK_QUEUE,msg);
//   }
//
//    public void sendTopic(Object message){
//        String msg = RedisService.beanToString(message);
//        amqpTemplate.convertAndSend(MQConfig.TOPIC_EXCHANGE,"topic.key1",msg+"1");
//    }
//
//}