diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java index 5c2e59dba..2f735b6eb 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java @@ -115,7 +115,9 @@ public class LettuceConnectionFactory implements InitializingBean, DisposableBea */ public void resetConnection() { synchronized (this.connectionMonitor) { - connection.close(); + if(this.connection != null) { + this.connection.close(); + } this.connection = null; } }