Fixed - semaphore object is not deleted after RLocalCachedMap.clearLocalCache method invocation. #2273

pull/2300/head
Nikita Koksharov 6 years ago
parent 8669589d7e
commit dc7206ab79

@ -255,7 +255,14 @@ public abstract class LocalCacheListener {
return;
}
result.trySuccess(null);
semaphore.deleteAsync().onComplete((re, exc) -> {
if (exc != null) {
result.tryFailure(exc);
return;
}
result.trySuccess(null);
});
});
});

@ -314,7 +314,10 @@ public class RedissonLocalCachedMapTest extends BaseMapTest {
assertThat(cache1.size()).isEqualTo(2);
assertThat(cache2.size()).isEqualTo(2);
map1.clearLocalCache();
assertThat(redisson.getKeys().count()).isEqualTo(1);
assertThat(cache1.size()).isZero();
assertThat(cache2.size()).isZero();

Loading…
Cancel
Save