From ea9a2f824326807a0c08065434ecc6044537f5e1 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Wed, 29 Apr 2020 11:01:43 +0300 Subject: [PATCH] refactoring --- .../org/redisson/connection/MasterSlaveConnectionManager.java | 4 ++-- .../java/org/redisson/pubsub/PublishSubscribeService.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java b/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java index 5a3e4a494..ef1cdbab6 100644 --- a/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java +++ b/redisson/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java @@ -632,9 +632,9 @@ public class MasterSlaveConnectionManager implements ConnectionManager { protected RFuture createNodeNotFoundFuture(NodeSource source) { RedisNodeNotFoundException ex; if (source.getSlot() != null && source.getAddr() == null && source.getRedisClient() == null) { - ex = new RedisNodeNotFoundException("Node for slot: " + source.getSlot() + " hasn't been discovered yet. Check cluster slots coverage using CLUSTER NODES command"); + ex = new RedisNodeNotFoundException("Node for slot: " + source.getSlot() + " hasn't been discovered yet. Check cluster slots coverage using CLUSTER NODES command. Increase value of retryAttempts and/or retryInterval settings."); } else { - ex = new RedisNodeNotFoundException("Node: " + source + " hasn't been discovered yet."); + ex = new RedisNodeNotFoundException("Node: " + source + " hasn't been discovered yet. Increase value of retryAttempts and/or retryInterval settings."); } return RedissonPromise.newFailedFuture(ex); } diff --git a/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java b/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java index 26aead899..e1ff9757e 100644 --- a/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java +++ b/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java @@ -267,7 +267,7 @@ public class PublishSubscribeService { private RFuture nextPubSubConnection(int slot) { MasterSlaveEntry entry = connectionManager.getEntry(slot); if (entry == null) { - RedisNodeNotFoundException ex = new RedisNodeNotFoundException("Node for slot: " + slot + " hasn't been discovered yet. Check cluster slots coverage using CLUSTER NODES command"); + RedisNodeNotFoundException ex = new RedisNodeNotFoundException("Node for slot: " + slot + " hasn't been discovered yet. Check cluster slots coverage using CLUSTER NODES command. Increase value of retryAttempts and/or retryInterval settings."); return RedissonPromise.newFailedFuture(ex); } return entry.nextPubSubConnection();