From 9cb42dd9d989384be63d60a451b1374b631efebc Mon Sep 17 00:00:00 2001 From: hongawen <83944980@qq.com> Date: Thu, 10 Aug 2023 19:20:56 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 2 +- .../com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java | 1 - .../middle/rocket/handler/EnhanceConsumerMessageHandler.java | 1 - 3 files changed, 1 insertion(+), 3 deletions(-) diff --git a/README.md b/README.md index 3f018ea..3549879 100644 --- a/README.md +++ b/README.md @@ -48,7 +48,7 @@ logging: #### 1、RocketMQ官方sdk中存在的问题: -##### 1.1、不支持LocalDate 和 LocalDateTim +##### 1.1、不支持LocalDate 和 LocalDateTime ​ 原因:RocketMQ内置使用的转换器是**RocketMQMessageConverter**,转换Json时使用的是MappingJackson2MessageConverter,但是这个转换器不支持时间类型。 diff --git a/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java b/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java index dd46e08..9345ed1 100644 --- a/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java +++ b/src/main/java/com/njcn/middle/rocket/autoconfig/RocketMQLogEnhance.java @@ -11,7 +11,6 @@ public class RocketMQLogEnhance implements InitializingBean { @Override public void afterPropertiesSet() throws Exception { - System.out.println("配置rocket日志"); System.setProperty("rocketmq.client.logUseSlf4j", "true"); } } \ No newline at end of file diff --git a/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java b/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java index 162d8d7..69bb006 100644 --- a/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java +++ b/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java @@ -103,7 +103,6 @@ public abstract class EnhanceConsumerMessageHandler { public void dispatchMessage(T message) { // 基础日志记录被父类处理了 log.info("消费者收到消息[{}]", JSONObject.toJSON(message)); - if (filter(message)) { log.info("消息id{}不满足消费条件,已过滤。", message.getKey()); return;