//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");
//    }
//
//}