Re-subscribe to the scaling channel when the connection drops

laravel · Sep 21, 2024 · 3ef9b6b · 3ef9b6b
1 parent 3adc873
commit 3ef9b6b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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);
+            }
+        });
     }
 
     /**