diff --git a/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java b/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java index 517b315e9..5768415d6 100644 --- a/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java +++ b/redisson/src/main/java/org/redisson/client/protocol/RedisCommands.java @@ -328,7 +328,7 @@ public interface RedisCommands { RedisStrictCommand DEL = new RedisStrictCommand("DEL"); RedisStrictCommand DBSIZE = new RedisStrictCommand("DBSIZE"); RedisStrictCommand DEL_BOOL = new RedisStrictCommand("DEL", new BooleanNullSafeReplayConvertor()); - RedisStrictCommand DEL_OBJECTS = new RedisStrictCommand("DEL", new BooleanNullSafeReplayConvertor()); + RedisStrictCommand DEL_OBJECTS = new RedisStrictCommand("DEL", new BooleanAmountReplayConvertor()); RedisStrictCommand DEL_VOID = new RedisStrictCommand("DEL", new VoidReplayConvertor()); RedisStrictCommand UNLINK = new RedisStrictCommand("UNLINK"); diff --git a/redisson/src/test/java/org/redisson/RedissonRateLimiterTest.java b/redisson/src/test/java/org/redisson/RedissonRateLimiterTest.java index 790e2a872..5ef83584a 100644 --- a/redisson/src/test/java/org/redisson/RedissonRateLimiterTest.java +++ b/redisson/src/test/java/org/redisson/RedissonRateLimiterTest.java @@ -164,7 +164,22 @@ public class RedissonRateLimiterTest extends BaseTest { Thread.sleep(1050); } } - + + @Test + public void testRemove() { + RRateLimiter rateLimiter = redisson.getRateLimiter("test"); + assertThat(rateLimiter.delete()).isFalse(); + + rateLimiter.trySetRate(RateType.OVERALL, 5L, 5L, RateIntervalUnit.MINUTES); + assertThat(redisson.getKeys().count()).isEqualTo(1); + + rateLimiter.tryAcquire(); + + boolean deleted = rateLimiter.delete(); + assertThat(redisson.getKeys().count()).isEqualTo(0); + assertThat(deleted).isTrue(); + } + @Test public void testConcurrency() throws InterruptedException { RRateLimiter rr = redisson.getRateLimiter("test");