Results
4
comments of
Paul
@component @RocketMQMessageListener(topic = "LB-COMMON",tag = "test") public class AB extends AbstractMessageListener { @Override public void handle(MessageEvent s) { Object domain = s.getDomain(); System.out.println(s.getDomain() instanceof User); System.out.println(s.toString()); } } 注： 把MessageEvent封装成通用的对象，你仅需要把你发送的对象放入setDomain()，消费端接受处理就行
目前，仅是公司内部再用啊