Skip to content

Commit 56fe2ec

Browse files
authored
chore: fix error handling (#67)
1 parent eb9d710 commit 56fe2ec

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

lib/redis_client/cluster/router.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ def send_command(method, *args, **kwargs, &block) # rubocop:disable Metrics/AbcS
5353
node = assign_node(*command)
5454
try_send(node, method, *args, **kwargs, &block)
5555
end
56-
rescue RedisClient::Cluster::Node::ReloadNeeded
56+
rescue ::RedisClient::Cluster::Node::ReloadNeeded
5757
update_cluster_info!
5858
raise ::RedisClient::Cluster::NodeMightBeDown
5959
end
@@ -137,7 +137,7 @@ def find_node(node_key, retry_count: 3)
137137

138138
def send_wait_command(method, *args, retry_count: 3, **kwargs, &block)
139139
@node.call_primaries(method, *args, **kwargs, &block).select { |r| r.is_a?(Integer) }.sum
140-
rescue RedisClient::Cluster::ErrorCollection => e
140+
rescue ::RedisClient::Cluster::ErrorCollection => e
141141
raise if retry_count <= 0
142142
raise if e.errors.values.none? do |err|
143143
err.message.include?('WAIT cannot be used with replica instances')
@@ -245,7 +245,7 @@ def update_cluster_info!
245245
@mutex.synchronize do
246246
begin
247247
@node.call_all(:close)
248-
rescue StandardError
248+
rescue ::RedisClient::Cluster::ErrorCollection
249249
# ignore
250250
end
251251

0 commit comments

Comments
 (0)