Fixed - RPriorityQueue has incorrect lock name if NameMapper was specified

pull/5329/head
Nikita Koksharov 1 year ago
parent a7cea0a63e
commit 6186b1c3b3

@ -79,7 +79,7 @@ public class RedissonPriorityQueue<V> extends RedissonList<V> implements RPriori
this.commandExecutor = commandExecutor; this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE); comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getRawName() + "}"); lock = redisson.getLock(getLockName());
} }
public RedissonPriorityQueue(Codec codec, CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson) { public RedissonPriorityQueue(Codec codec, CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson) {
@ -87,7 +87,11 @@ public class RedissonPriorityQueue<V> extends RedissonList<V> implements RPriori
this.commandExecutor = commandExecutor; this.commandExecutor = commandExecutor;
comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE); comparatorHolder = redisson.getBucket(getComparatorKeyName(), StringCodec.INSTANCE);
lock = redisson.getLock("redisson_sortedset_lock:{" + getRawName() + "}"); lock = redisson.getLock(getLockName());
}
private String getLockName() {
return prefixName("redisson_sortedset_lock", getName());
} }
private void loadComparator() { private void loadComparator() {

Loading…
Cancel
Save