Undo changes must be the redist broadcaster

Author: lionslair

src/PubSub/Drivers/LocalClient.php

@@ -34,10 +34,10 @@ public function boot(LoopInterface $loop, $factoryClass = null): ReplicationInte
      *
      * @param  string  $appId
      * @param  string  $channel
-     * @param  array  $payload
+     * @param  stdClass  $payload
      * @return bool
      */
-    public function publish($appId, string $channel, array $payload): bool
+    public function publish($appId, string $channel, stdClass $payload): bool
     {
         return true;
     }

src/PubSub/Drivers/RedisClient.php

@@ -94,10 +94,10 @@ public function boot(LoopInterface $loop, $factoryClass = null): ReplicationInte
      *
      * @param  string  $appId
      * @param  string  $channel
-     * @param  array  $payload
+     * @param  stdClass  $payload
      * @return bool
      */
-    public function publish($appId, string $channel, array $payload): bool
+    public function publish($appId, string $channel, stdClass $payload): bool
     {
         $payload->appId = $appId;
         $payload->serverId = $this->getServerId();

src/PubSub/ReplicationInterface.php

@@ -22,10 +22,10 @@ public function boot(LoopInterface $loop, $factoryClass = null): self;
      *
      * @param  string  $appId
      * @param  string  $channel
-     * @param  array  $payload
+     * @param  stdClass  $payload
      * @return bool
      */
-    public function publish($appId, string $channel, array $payload): bool;
+    public function publish($appId, string $channel, stdClass $payload): bool;
 
     /**
      * Subscribe to receive messages for a channel.

tests/PubSub/RedisDriverTest.php

@@ -30,12 +30,12 @@ public function redis_listener_responds_properly_on_payload()
             ],
         ];
 
-        $payload = [
+        $payload = json_encode([
             'appId' => '1234',
             'event' => 'test',
             'data' => $channelData,
             'socket' => $connection->socketId,
-        ];
+        ]);
 
         $this->getSubscribeClient()->onMessage('1234:test-channel', $payload);