diff --git a/src/Servers/Reverb/Publishing/RedisPubSubProvider.php b/src/Servers/Reverb/Publishing/RedisPubSubProvider.php index dde3438..84f0ff9 100644 --- a/src/Servers/Reverb/Publishing/RedisPubSubProvider.php +++ b/src/Servers/Reverb/Publishing/RedisPubSubProvider.php @@ -56,6 +56,12 @@ public function subscribe(): void $this->subscribingClient->on('message', function (string $channel, string $payload) { $this->messageHandler->handle($payload); }); + + $this->subscribingClient->on('unsubscribe', function (string $channel) { + if($this->channel === $channel){ + $this->subscribingClient->subscribe($channel); + } + }); } /**