
7 changed files with 35 additions and 9 deletions
@ -0,0 +1,15 @@ |
|||||
|
package demo.rocketmq; |
||||
|
|
||||
|
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; |
||||
|
import org.apache.rocketmq.spring.core.RocketMQListener; |
||||
|
import org.springframework.stereotype.Component; |
||||
|
|
||||
|
//@Component
|
||||
|
//@RocketMQMessageListener(consumerGroup = "monitorConsumer", topic = "sanyouTopic")
|
||||
|
public class MqClientListener implements RocketMQListener<String> { |
||||
|
|
||||
|
@Override |
||||
|
public void onMessage(String msg) { |
||||
|
System.out.println("接收到消息:" + msg); |
||||
|
} |
||||
|
} |
Loading…
Reference in new issue