From daa697719eb0ddfd170f1ab94c5422a4f5b93951 Mon Sep 17 00:00:00 2001 From: zhaoxiaohao <279049017@qq.com> Date: Fri, 18 Sep 2020 14:36:54 +0800 Subject: [PATCH] Merge branch 'dev' --- kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/send/TopicSender.java | 31 +++++++++++++++++++++++++++++++ 1 files changed, 31 insertions(+), 0 deletions(-) diff --git a/kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/send/TopicSender.java b/kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/send/TopicSender.java new file mode 100644 index 0000000..9cb3373 --- /dev/null +++ b/kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/send/TopicSender.java @@ -0,0 +1,31 @@ +package com.kidgrow.rabbitmq.send; + +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br> + * + * @Description: <br> + * @Project: <br> + * @CreateDate: Created in 2020/3/23 18:45 <br> + * @Author: <a href="4345453@kidgrow.com">liuke</a> + */ +@Component +public class TopicSender { +// @Autowired +// private AmqpTemplate rabbitTemplate; + + @Autowired + private RabbitTemplate rabbitTemplate; + + + public void send() { + for(int i=1;i<10000;i++) { + String context = "hi, i am message:"+i; + this.rabbitTemplate.setQueue("AIEvaluation"); + this.rabbitTemplate.convertAndSend("test_exchange", "test_routingKey", context); + } + } +} -- Gitblit v1.8.0