From 58fb78fd9ab224f9754b9b9fcb61c2fcdb3bb668 Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 30 Nov 2015 11:15:16 +0300 Subject: [PATCH] ClusterNode.info fixed --- .../java/org/redisson/connection/RedisClientEntry.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/redisson/connection/RedisClientEntry.java b/src/main/java/org/redisson/connection/RedisClientEntry.java index 112ab541d..289d9dae0 100644 --- a/src/main/java/org/redisson/connection/RedisClientEntry.java +++ b/src/main/java/org/redisson/connection/RedisClientEntry.java @@ -94,13 +94,16 @@ public class RedisClientEntry implements ClusterNode { @Override public Map info() { - RedisConnection c = connect(); + RedisConnection c = null; try { + c = connect(); return c.sync(RedisCommands.CLUSTER_INFO); } catch (Exception e) { return null; } finally { - c.closeAsync(); + if (c != null) { + c.closeAsync(); + } } }