feat(REQ-2516): 添加 Consumer 的 Setter 注解

2024-06-14 09:57:42 +08:00 · 2024-06-14 09:57:42 +08:00 · 8de3080da8
commit 8de3080da8
parent 6199411c3b
1 changed files with 2 additions and 0 deletions
--- a/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/EventConsumer.java
+++ b/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/EventConsumer.java
@ -80,10 +80,12 @@ public interface EventConsumer {
        /**
         * 只elapse 超过多少毫秒才进行日志记录。默认 3ms
         */
+        @Setter
        private Long logElapsedThreshold;

        private Map<String, byte[]> headers;
        private Map<String, Object> ext;
+        @Setter
        private Long maxAllowElapsedMillis;
        private Boolean logEnabled;
        private transient Predicate<Event> logFilter;