Skip to content

M
matrix
Commit 2af3b0fa by QIANGLU
Options

重试开关

parent 913c9dc5
Showing with 1 additions and 1 deletions
rocketmq-starter/src/main/java/com/secoo/mall/mq/config/MatrixListenerContainerConfiguration.java
...@@ -18,7 +18,7 @@ public class MatrixListenerContainerConfiguration implements BeanPostProcessor { ...@@ -18,7 +18,7 @@ public class MatrixListenerContainerConfiguration implements BeanPostProcessor {
private final static Logger log = LoggerFactory.getLogger(MatrixListenerContainerConfiguration.class); private final static Logger log = LoggerFactory.getLogger(MatrixListenerContainerConfiguration.class);
@Value("${matrix.rocketmq.consumer.delayLevel:-1}") @Value("${matrix.rocketmq.consumer.delayLevel:0}")
private int delayLevel; private int delayLevel;
@Bean @Bean
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment