对于mq中间件的支持
目前Tlog对于消息中间件的支持是有侵入性的,暂时无法做到完全无侵入。
对于客户端,你只需要用TLogMqWrapBean
包装你的业务bean就可以了。
TLogMqWrapBean<BizBean> tLogMqWrap = new TLogMqWrapBean(bizBean);
mqClient.send(tLogMqWrap);
对于消费者端,你需要这么做:
//从mq里接受到tLogMqWrapBean
TLogMqConsumerProcessor.process(tLogMqWrapBean, new TLogMqRunner<BizBean>() {
@Override
public void mqConsume(BizBean o) {
//业务操作
}
});
帮助我们改善文档 (opens new window)
last update: 2022/09/21, 16:00:22