github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

text fixed

Browse Source
pull/5661/head
Nikita Koksharov 1 year ago
parent 3c077ab3bc
commit 536b445fa8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File

2
redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java
Unescape Escape View File

@ -407,7 +407,7 @@ public class PublishSubscribeService {
Timeout lockTimeout = connectionManager.getServiceManager().newTimeout(t -> { Timeout lockTimeout = connectionManager.getServiceManager().newTimeout(t -> {
promise.completeExceptionally(new RedisTimeoutException( promise.completeExceptionally(new RedisTimeoutException(
"Unable to acquire subscription lock after " + timeout + "ms. " + "Unable to acquire subscription lock after " + timeout + "ms. " +
"Try to increase 'timeout', 'subscriptionsPerConnection', 'subscriptionConnectionPoolSize' parameters.")); "Try to increase 'subscriptionTimeout', 'subscriptionsPerConnection', 'subscriptionConnectionPoolSize' parameters."));
}, timeout, TimeUnit.MILLISECONDS); }, timeout, TimeUnit.MILLISECONDS);
lock.acquire().thenAccept(r -> { lock.acquire().thenAccept(r -> {
if (!lockTimeout.cancel() || promise.isDone()) { if (!lockTimeout.cancel() || promise.isDone()) {

Write Preview
Loading…
Cancel
Save