From a631fafe64bc0893886962395f7af74d28c474d0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=A7=A6=E8=8B=B1=E6=9D=B0?= <327782001@qq.com>
Date: Fri, 26 May 2023 15:05:39 +0800
Subject: [PATCH] =?UTF-8?q?fix:springboot=E9=9B=86=E6=88=90rocketmq?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/cn/itcast/mq/Consumer.java                 | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/springboot-rocketmq-consumer/src/main/java/cn/itcast/mq/Consumer.java b/springboot-rocketmq-consumer/src/main/java/cn/itcast/mq/Consumer.java
index 7849428..55003e0 100644
--- a/springboot-rocketmq-consumer/src/main/java/cn/itcast/mq/Consumer.java
+++ b/springboot-rocketmq-consumer/src/main/java/cn/itcast/mq/Consumer.java
@@ -1,4 +1,5 @@
 package cn.itcast.mq;
+
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
@@ -6,11 +7,11 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-@RocketMQMessageListener(topic = "springboot-mq",consumerGroup = "springboot-mq-consumer-1")
+@RocketMQMessageListener(topic = "springboot-mq", consumerGroup = "springboot-mq-consumer-1")
 public class Consumer implements RocketMQListener<String> {
 
     @Override
     public void onMessage(String message) {
-        log.info("Receive message："+message);
+        log.info("Receive message：" + message);
     }
 }
-- 
GitLab