@Test
public void testReacquireLostKey() throws InterruptedException {

    redisson.getKeys().flushall();
    String lockId = "abcd-1234";
    boolean isLocked = redisLock.acquireLock(lockId, 1000, 10000, TimeUnit.MILLISECONDS);
    assertTrue(isLocked);
    // Delete key from the cluster to reacquire
    // Simulating the case when cluster goes down and possibly loses some keys.
    redisson.getKeys().flushall();
    isLocked = redisLock.acquireLock(lockId, 100, 10000, TimeUnit.MILLISECONDS);
    assertTrue(isLocked);
}