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