diff --git a/redisson/src/main/java/org/redisson/RedissonRateLimiter.java b/redisson/src/main/java/org/redisson/RedissonRateLimiter.java index e85bccabf..072fe3e1c 100644 --- a/redisson/src/main/java/org/redisson/RedissonRateLimiter.java +++ b/redisson/src/main/java/org/redisson/RedissonRateLimiter.java @@ -205,7 +205,7 @@ public class RedissonRateLimiter extends RedissonExpirable implements RRateLimit + "end; " + "if released > 0 then " - + "redis.call('zrem', permitsName, unpack(expiredValues)); " + + "redis.call('zremrangebyscore', permitsName, 0, tonumber(ARGV[2]) - interval); " + "currentValue = tonumber(currentValue) + released; " + "redis.call('set', valueName, currentValue);" + "end;" @@ -320,7 +320,7 @@ public class RedissonRateLimiter extends RedissonExpirable implements RRateLimit + "end; " + "if released > 0 then " - + "redis.call('zrem', permitsName, unpack(expiredValues)); " + + "redis.call('zremrangebyscore', permitsName, 0, tonumber(ARGV[1]) - interval); " + "currentValue = tonumber(currentValue) + released; " + "redis.call('set', valueName, currentValue);" + "end;"