diff --git a/src/main/java/redis/clients/jedis/BinaryJedisPubSub.java b/src/main/java/redis/clients/jedis/BinaryJedisPubSub.java index 96123256c6..cf1c0ae8a5 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedisPubSub.java +++ b/src/main/java/redis/clients/jedis/BinaryJedisPubSub.java @@ -6,4 +6,5 @@ public abstract class BinaryJedisPubSub extends JedisPubSubBase { protected final byte[] encode(byte[] raw) { return raw; } + } diff --git a/src/main/java/redis/clients/jedis/JedisPubSubBase.java b/src/main/java/redis/clients/jedis/JedisPubSubBase.java index 7092680e33..091a21e257 100644 --- a/src/main/java/redis/clients/jedis/JedisPubSubBase.java +++ b/src/main/java/redis/clients/jedis/JedisPubSubBase.java @@ -174,7 +174,5 @@ private void process() { } } while (isSubscribed()); -// /* Invalidate instance since this thread is no longer listening */ -// this.client = null; } }