diff --git a/tests/PubSub/RedisDriverTest.php b/tests/PubSub/RedisDriverTest.php
new file mode 100644
index 0000000..0558e25
--- /dev/null
+++ b/tests/PubSub/RedisDriverTest.php
@@ -0,0 +1,52 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Tests\PubSub;
+
+use BeyondCode\LaravelWebSockets\PubSub\Drivers\RedisClient;
+use BeyondCode\LaravelWebSockets\Tests\TestCase;
+use React\EventLoop\Factory as LoopFactory;
+use BeyondCode\LaravelWebSockets\Tests\Mocks\RedisFactory;
+
+class RedisDriverTest extends TestCase
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function setUp(): void
+    {
+        parent::setUp();
+
+        $this->runOnlyOnRedisReplication();
+    }
+
+    /** @test */
+    public function redis_listener_responds_properly_on_payload()
+    {
+        $connection = $this->getConnectedWebSocketConnection(['test-channel']);
+
+        $this->pusherServer->onOpen($connection);
+
+        $channelData = [
+            'user_id' => 1,
+            'user_info' => [
+                'name' => 'Marcel',
+            ],
+        ];
+
+        $payload = json_encode([
+            'appId' => '1234',
+            'event' => 'test',
+            'data' => $channelData,
+            'socket' => $connection->socketId,
+        ]);
+
+        $this->getSubscribeClient()->onMessage('1234:test-channel', $payload);
+
+        $this->getSubscribeClient()
+            ->assertEventDispatched('message')
+            ->assertCalledWithArgs('subscribe', ['1234:test-channel'])
+            ->assertCalledWithArgs('onMessage', [
+                '1234:test-channel', $payload,
+            ]);
+    }
+}