diff --git a/lib/Predis/PubSub/Consumer.php b/lib/Predis/PubSub/Consumer.php index cf219ca2..13fea361 100644 --- a/lib/Predis/PubSub/Consumer.php +++ b/lib/Predis/PubSub/Consumer.php @@ -119,6 +119,8 @@ class Consumer extends AbstractConsumer if ($response[2] === 0) { $this->invalidate(); } + // The missing break here is intentional as we must process + // subscriptions and unsubscriptions as standard messages. case self::MESSAGE: return (object) array(