diff --git a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/ConsumerListener.java b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/RabbitConsumer.java similarity index 90% rename from ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/ConsumerListener.java rename to ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/RabbitConsumer.java index c131509f..f12e653c 100644 --- a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/ConsumerListener.java +++ b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/RabbitConsumer.java @@ -13,12 +13,11 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -public class ConsumerListener { +public class RabbitConsumer { /** - * 设置监听哪一个队列 这个队列是RabbitConfig里面设置好的队列名字 * 普通消息 - **/ + */ @RabbitListener(queues = RabbitConfig.QUEUE_NAME) public void listenQueue(Message message) { log.info("【消费者】Start consuming data:{}",new String(message.getBody()));