diff --git 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 index e782d67..68468d5 100644 --- 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 headers; private Map ext; + @Setter private Long maxAllowElapsedMillis; private Boolean logEnabled; private transient Predicate logFilter;