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;