readMe有问题

[zkoalas]

写消费者的时候，如果范型上不能用User，会 报ClassException异常 因为你发送过来的是MessageEvent对象

@Component @RocketMQMessageListener(topic = "LB-COMMON",tag = "test") public class AB extends AbstractMessageListener<MessageEvent> {

@Override
public void handle(MessageEvent s) {
    Object domain = s.getDomain();
    System.out.println(s.getDomain() instanceof User);
    System.out.println(s.toString());
}

}

[jibaole]

@component @RocketMQMessageListener(topic = "LB-COMMON",tag = "test") public class AB extends AbstractMessageListener<MessageEvent> { @Override public void handle(MessageEvent s) { Object domain = s.getDomain(); System.out.println(s.getDomain() instanceof User); System.out.println(s.toString()); } }

注： 把MessageEvent封装成通用的对象，你仅需要把你发送的对象放入setDomain()，消费端接受处理就行

[liujweb]

阿里云MQ是区分公网，生产环境，上面注解topic注解方式 如何根据环境动态变化呢？