forked from kidgrow-microservices-platform

侯瑞军
2020-05-06 528fa00bade64ddc7aa2c9978d37e2ab5168afd1
kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/send/TopicSender.java
@@ -1,6 +1,6 @@
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;
@@ -14,12 +14,17 @@
 */
@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);
        }
    }