提交 a631fafe 编写于 作者: 檀越@新空间's avatar 檀越@新空间 🐭

fix:springboot集成rocketmq

上级 261fb5ee
package cn.itcast.mq; package cn.itcast.mq;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
...@@ -6,11 +7,11 @@ import org.springframework.stereotype.Component; ...@@ -6,11 +7,11 @@ import org.springframework.stereotype.Component;
@Slf4j @Slf4j
@Component @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> { public class Consumer implements RocketMQListener<String> {
@Override @Override
public void onMessage(String message) { public void onMessage(String message) {
log.info("Receive message:"+message); log.info("Receive message:" + message);
} }
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册