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 7849428f259e19d0515c635d9a591a7746683c8a..55003e05fe6639221c8042347d5a4434f75b44cb 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 { @Override public void onMessage(String message) { - log.info("Receive message:"+message); + log.info("Receive message:" + message); } }