@@ -123,6 +123,7 @@ class Consumer extends AbstractConsumer
}
// The missing break here is intentional as we must process
// subscriptions and unsubscriptions as standard messages.
+ // no break
case self::MESSAGE:
return (object) array(
@@ -909,6 +909,7 @@ class MultiExecTest extends PredisTestCase
case 'UNWATCH':
$watch = false;
default:
return $multi ? new Response\Status('QUEUED') : 'DUMMY_RESPONSE';