| | |
| | | package com.kidgrow.rabbitmq.send; |
| | | |
| | | import org.springframework.amqp.core.AmqpTemplate; |
| | | import org.springframework.amqp.rabbit.core.RabbitTemplate; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | |
| | | */ |
| | | @Component |
| | | public class TopicSender { |
| | | // @Autowired |
| | | // private AmqpTemplate rabbitTemplate; |
| | | |
| | | @Autowired |
| | | private AmqpTemplate rabbitTemplate; |
| | | 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); |
| | | } |
| | | } |