何冠元 / canal-mq-client · 提交

转到一个项目

作者 [wgf]
提交 2c602c40f34ad3f6e25af6ffa02bb40c10699456 1 个父辈 8b5b8602

修改日志打印

内嵌 并排对比
正在显示 2 个修改的文件 包含 2 行增加 和 10 行删除
... ... @@ -33,14 +33,12 @@ public class AmazonOrderItemListener {
try {
log.info("接收到队列: {} 消息：{}", MQConst.TEST, message);
MessageVo<AmazonOrderItem> messageVo = JSON.parseObject(message, new TypeReference<MessageVo<AmazonOrderItem>>() {
});
EventType eventType = EventType.valueOf(messageVo.getType());
log.info("当前监听binlog 数据库：{}, 数据表：{}", messageVo.getDatabase(), messageVo.getTable());
log.info("当前监听binlog 数据库：{}, 数据表：{}, 数据：{}", messageVo.getDatabase(), messageVo.getTable(), message);
// 数据同步只关注这三种事件
switch (eventType) {
... ... @@ -60,8 +58,6 @@ public class AmazonOrderItemListener {
log.info("其他事件类型：{}, 过滤不处理", eventType);
}
log.info("消息长度：{}", messageVo.getData().size());
/**
* 消息消费确认
* 如果客户端在线没有签收没有签收这条Message，则此消息进入Unacked状态，此时监听器阻塞等待消息确认，不推送新Message
... ...
... ... @@ -33,14 +33,12 @@ public class AmazonOrderListener {
try {
log.info("接收到队列: {} 消息：{}", MQConst.TEST, message);
MessageVo<AmazonOrder> messageVo = JSON.parseObject(message, new TypeReference<MessageVo<AmazonOrder>>() {
});
EventType eventType = EventType.valueOf(messageVo.getType());
log.info("当前监听binlog 数据库：{}, 数据表：{}", messageVo.getDatabase(), messageVo.getTable());
log.info("当前监听binlog 数据库：{}, 数据表：{}, 数据：{}", messageVo.getDatabase(), messageVo.getTable(), message);
// 数据同步只关注这三种事件
switch (eventType) {
... ... @@ -60,8 +58,6 @@ public class AmazonOrderListener {
log.info("其他事件类型：{}, 过滤不处理", eventType);
}
log.info("消息长度：{}", messageVo.getData().size());
/**
* 消息消费确认
* 如果客户端在线没有签收没有签收这条Message，则此消息进入Unacked状态，此时监听器阻塞等待消息确认，不推送新Message
... ...