Remove duplicate command checks from disconnected and command buffers #…

…615
redis · Feb 16, 2018 · 15e5a6b · 15e5a6b
1 parent d1459f7
commit 15e5a6b
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/src/main/java/io/lettuce/core/protocol/DefaultEndpoint.java b/src/main/java/io/lettuce/core/protocol/DefaultEndpoint.java
@@ -214,10 +214,6 @@ private void writeToDisconnectedBuffer(Collection<? extends RedisCommand<?, ?, ?
 
     private void writeToDisconnectedBuffer(RedisCommand<?, ?, ?> command) {
 
-        if (disconnectedBuffer.contains(command)) {
-            return;
-        }
-
         if (connectionError != null) {
             if (debugEnabled) {
                 logger.debug("{} writeToDisconnectedBuffer() Completing command {} due to connection error", logPrefix(),
@@ -237,10 +233,6 @@ private void writeToDisconnectedBuffer(RedisCommand<?, ?, ?> command) {
 
     protected <C extends RedisCommand<?, ?, T>, T> void writeToBuffer(C command) {
 
-        if (commandBuffer.contains(command)) {
-            return;
-        }
-
         if (debugEnabled) {
             logger.debug("{} writeToBuffer() buffering command {}", logPrefix(), command);
         }