This is an automated email from the ASF dual-hosted git repository.

xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-shenyu.git


The following commit(s) were added to refs/heads/master by this push:
     new 457a0ed  change to Duration.ofMiles to avoid calculate manually (#2925)
457a0ed is described below

commit 457a0ed29d142a817f7023ad9b02733ec5aa3f46
Author: Han Gao <[email protected]>
AuthorDate: Wed Feb 23 10:53:55 2022 +0800

    change to Duration.ofMiles to avoid calculate manually (#2925)
---
 .../shenyu/plugin/resilience4j/build/Resilience4JBuilder.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
 
b/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
index 61b1ece..6a97b9f 100644
--- 
a/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
+++ 
b/shenyu-plugin/shenyu-plugin-resilience4j/src/main/java/org/apache/shenyu/plugin/resilience4j/build/Resilience4JBuilder.java
@@ -56,15 +56,15 @@ public final class Resilience4JBuilder {
                             handle.getSlidingWindowType() == 0
                                     ? 
CircuitBreakerConfig.SlidingWindowType.COUNT_BASED
                                     : 
CircuitBreakerConfig.SlidingWindowType.TIME_BASED).waitIntervalFunctionInOpenState(IntervalFunction
-                            
.of(Duration.ofSeconds(handle.getWaitIntervalFunctionInOpenState() / 1000)))
+                            
.of(Duration.ofMillis(handle.getWaitIntervalFunctionInOpenState())))
                     
.permittedNumberOfCallsInHalfOpenState(handle.getPermittedNumberOfCallsInHalfOpenState()).build();
         }
         TimeLimiterConfig timeLimiterConfig = TimeLimiterConfig.custom()
-                
.timeoutDuration(Duration.ofSeconds(handle.getTimeoutDuration() / 
1000)).build();
+                
.timeoutDuration(Duration.ofMillis(handle.getTimeoutDuration())).build();
         RateLimiterConfig rateLimiterConfig = RateLimiterConfig.custom()
                 .limitForPeriod(handle.getLimitForPeriod())
-                
.timeoutDuration(Duration.ofSeconds(handle.getTimeoutDurationRate() / 1000))
-                
.limitRefreshPeriod(Duration.ofNanos(handle.getLimitRefreshPeriod() * 
1000000L)).build();
+                
.timeoutDuration(Duration.ofMillis(handle.getTimeoutDurationRate()))
+                
.limitRefreshPeriod(Duration.ofMillis(handle.getLimitRefreshPeriod())).build();
         return new Resilience4JConf(CacheKeyUtils.INST.getKey(ruleData), 
handle.getFallbackUri(), rateLimiterConfig, timeLimiterConfig, 
circuitBreakerConfig);
     }
 }

Reply via email to