@ -537,16 +537,6 @@ public class Redisson implements RedissonClient {
return new RedisNodes<ClusterNode>(connectionManager);
}
@Override
public void flushdb() {
commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHDB));
public void flushall() {
commandExecutor.get(commandExecutor.writeAllAsync(RedisCommands.FLUSHALL));
public boolean isShutdown() {
return connectionManager.isShutdown();
@ -658,18 +658,6 @@ public interface RedissonClient {
*/
NodesGroup<ClusterNode> getClusterNodesGroup();
/**
* Use {@link RKeys#flushdb()}
@Deprecated
void flushdb();
* Use {@link RKeys#flushall()}
void flushall();
* Returns {@code true} if this Redisson instance has been shut down.
*
@ -59,7 +59,7 @@ public class RedissonBucketTest extends BaseTest {
assertThat(r1.trySet("4", 500, TimeUnit.MILLISECONDS)).isFalse();
assertThat(r1.get()).isEqualTo("3");
Thread.sleep(500);
Thread.sleep(1000);
assertThat(r1.get()).isNull();
@ -94,7 +94,7 @@ public class RedissonConcurrentMapTest extends BaseConcurrentTest {
assertMapSize(5, name);
redisson.flushdb();
redisson.getKeys().flushdb();
redisson.shutdown();
@ -58,7 +58,7 @@ public class RedissonKeysTest extends BaseTest {
assertThat(redisson.getKeys().randomKey()).isIn("test1", "test2");
redisson.getKeys().delete("test1");
Assert.assertEquals(redisson.getKeys().randomKey(), "test2");
Assert.assertNull(redisson.getKeys().randomKey());
@ -102,7 +102,7 @@ public class RedissonSetMultimapCacheTest extends BaseTest {
multimap.put("1", "3");
multimap.expireKey("1", 1, TimeUnit.SECONDS);
Thread.sleep(1500);
assertThat(multimap.get("1").size()).isZero();
assertThat(multimap.get("1")).contains();