forked from kidgrow-microservices-platform

zhaoxiaohao
2021-04-16 efab482471f3e3ee330fd294d9f4a459eedf78fc
kidgrow-business/kidgrow-mqcenter/kidgrow-mqcenter-rabbit/src/main/java/com/kidgrow/rabbitmq/recieve/TopicReceive.java
@@ -15,7 +15,7 @@
 * @Author: <a href="4345453@kidgrow.com">liuke</a>
 */
@Component
@RabbitListener(queues = "test_queue")
@RabbitListener(queues = "AdvancedEvaluation")
public class TopicReceive {
    @RabbitHandler
    public void process(String messages, Message message, Channel channel) {
@@ -24,7 +24,7 @@
        try {
            System.out.println("Topic Receiver : " + messages);
            // 通知 MQ 消息已被成功消费,可以ACK了
            channel.basicAck(deliveryTag, false);
            channel.basicAck(deliveryTag, false);  channel.basicAck(deliveryTag, false);
        }
        catch (Exception e) {
            try {