diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSubscription.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSubscription.java index 2851b6a6c..bbbbd831d 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSubscription.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceSubscription.java @@ -27,6 +27,9 @@ import org.springframework.data.redis.connection.util.AbstractSubscription; * @author Costin Leau * @author Mark Paluch * @author Christoph Strobl + * @author Sarah Abbey + * @author Murtuza Boxwala + * @author Jens Deppe */ public class LettuceSubscription extends AbstractSubscription { @@ -67,11 +70,11 @@ public class LettuceSubscription extends AbstractSubscription { protected void doClose() { if (!getChannels().isEmpty()) { - doUnsubscribe(true, new byte[0]); + doUnsubscribe(true); } if (!getPatterns().isEmpty()) { - doPUnsubscribe(true, new byte[0]); + doPUnsubscribe(true); } connection.removeListener(this.listener);