diff --git a/docs/advanced-usage/dispatched-events.md b/docs/advanced-usage/dispatched-events.md
new file mode 100644
index 0000000000..be5e095b24
--- /dev/null
+++ b/docs/advanced-usage/dispatched-events.md
@@ -0,0 +1,82 @@
+---
+title: Dispatched Events
+order: 5
+---
+
+# Dispatched Events
+
+Laravel WebSockets takes advantage of Laravel's Event dispatching observer, in a way that you can handle in-server events outside of it.
+
+For example, you can listen for events like when a new connection establishes or when an user joins a presence channel.
+
+## Events
+
+Below you will find a list of dispatched events:
+
+- `BeyondCode\LaravelWebSockets\Events\NewConnection` - when a connection successfully establishes on the server
+- `BeyondCode\LaravelWebSockets\Events\ConnectionClosed` - when a connection leaves the server
+- `BeyondCode\LaravelWebSockets\Events\SubscribedToChannel` - when a connection subscribes to a specific channel
+- `BeyondCode\LaravelWebSockets\Events\UnsubscribedFromChannel` - when a connection unsubscribes from a specific channel
+- `BeyondCode\LaravelWebSockets\Events\WebSocketMessageReceived` - when the server receives a message
+- `BeyondCode\LaravelWebSockets\EventsConnectionPonged` - when a connection pings to the server that it is still alive
+
+## Queued Listeners
+
+Because the default Redis connection (either PhpRedis or Predis) is a blocking I/O method and can cause problems with the server speed and availability, you might want to check the [Non-Blocking Queue Driver](non-blocking-queue-driver.md) documentation that helps you create the Async Redis queue driver that is going to fix the Blocking I/O issue.
+
+If set up, you can use the `async-redis` queue driver in your listeners:
+
+```php
+<?php
+
+namespace App\Listeners;
+
+use BeyondCode\LaravelWebSockets\Events\NewConnection;
+use Illuminate\Contracts\Queue\ShouldQueue;
+
+class HandleNewConnections implements ShouldQueue
+{
+    /**
+     * The name of the connection the job should be sent to.
+     *
+     * @var string|null
+     */
+    public $connection = 'async-redis';
+
+    /**
+     * Create the event listener.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        //
+    }
+
+    /**
+     * Handle the event.
+     *
+     * @param  NewConnection  $event
+     * @return void
+     */
+    public function handle(NewConnection $event)
+    {
+        //
+    }
+}
+```
+
+The `EventServiceProvider` might look like this, registering the listeners that are going to be used by the event dispatching:
+
+```php
+/**
+ * The event listener mappings for the application.
+ *
+ * @var array
+ */
+protected $listen = [
+    \BeyondCode\LaravelWebSockets\Events\NewConnection::class => [
+        App\Listeners\HandleNewConnections::class,
+    ],
+];
+```
diff --git a/docs/advanced-usage/non-blocking-queue-driver.md b/docs/advanced-usage/non-blocking-queue-driver.md
new file mode 100644
index 0000000000..98ed10d1a8
--- /dev/null
+++ b/docs/advanced-usage/non-blocking-queue-driver.md
@@ -0,0 +1,30 @@
+---
+title: Non-Blocking Queue Driver
+order: 4
+---
+
+# Non-Blocking Queue Driver
+
+In Laravel, he default Redis connection also interacts with the queues. Since you might want to dispatch jobs on Redis from the server, you can encounter an anti-pattern of using a blocking I/O connection (like PhpRedis or PRedis) within the WebSockets server.
+
+To solve this issue, you can configure the built-in queue driver that uses the Async Redis connection when it's possible, like within the WebSockets server. It's highly recommended to switch your queue to it if you are going to use the queues within the server controllers, for example.
+
+Add the `async-redis` queue driver to your list of connections. The configuration parameters are compatible with the default `redis` driver:
+
+```php
+'connections' => [
+    'async-redis' => [
+        'driver' => 'async-redis',
+        'connection' => env('WEBSOCKETS_REDIS_REPLICATION_CONNECTION', 'default'),
+        'queue' => env('REDIS_QUEUE', 'default'),
+        'retry_after' => 90,
+        'block_for' => null,
+    ],
+]
+```
+
+Also, make sure that the default queue driver is set to `async-redis`:
+
+```
+QUEUE_CONNECTION=async-redis
+```
diff --git a/docs/horizontal-scaling/redis.md b/docs/horizontal-scaling/redis.md
index 86759db300..4f6383583b 100644
--- a/docs/horizontal-scaling/redis.md
+++ b/docs/horizontal-scaling/redis.md
@@ -40,29 +40,3 @@ You can set the connection name to the Redis database under `redis`:
 ```
 
 The connections can be found in your `config/database.php` file, under the `redis` key.
-
-## Async Redis Queue
-
-The default Redis connection also interacts with the queues. Since you might want to dispatch jobs on Redis from the server, you can encounter an anti-pattern of using a blocking I/O connection (like PhpRedis or PRedis) within the WebSockets server.
-
-To solve this issue, you can configure the built-in queue driver that uses the Async Redis connection when it's possible, like within the WebSockets server. It's highly recommended to switch your queue to it if you are going to use the queues within the server controllers, for example.
-
-Add the `async-redis` queue driver to your list of connections. The configuration parameters are compatible with the default `redis` driver:
-
-```php
-'connections' => [
-    'async-redis' => [
-        'driver' => 'async-redis',
-        'connection' => env('WEBSOCKETS_REDIS_REPLICATION_CONNECTION', 'default'),
-        'queue' => env('REDIS_QUEUE', 'default'),
-        'retry_after' => 90,
-        'block_for' => null,
-    ],
-]
-```
-
-Also, make sure that the default queue driver is set to `async-redis`:
-
-```
-QUEUE_CONNECTION=async-redis
-```
diff --git a/src/Channels/Channel.php b/src/Channels/Channel.php
index e64a4d1ac2..fd857e233f 100644
--- a/src/Channels/Channel.php
+++ b/src/Channels/Channel.php
@@ -4,6 +4,8 @@
 
 use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
 use BeyondCode\LaravelWebSockets\DashboardLogger;
+use BeyondCode\LaravelWebSockets\Events\SubscribedToChannel;
+use BeyondCode\LaravelWebSockets\Events\UnsubscribedFromChannel;
 use BeyondCode\LaravelWebSockets\Server\Exceptions\InvalidSignature;
 use Illuminate\Support\Str;
 use Ratchet\ConnectionInterface;
@@ -89,6 +91,12 @@ public function subscribe(ConnectionInterface $connection, stdClass $payload): b
             'channel' => $this->getName(),
         ]);
 
+        SubscribedToChannel::dispatch(
+            $connection->app->id,
+            $connection->socketId,
+            $this->getName(),
+        );
+
         return true;
     }
 
@@ -106,6 +114,12 @@ public function unsubscribe(ConnectionInterface $connection): bool
 
         unset($this->connections[$connection->socketId]);
 
+        UnsubscribedFromChannel::dispatch(
+            $connection->app->id,
+            $connection->socketId,
+            $this->getName()
+        );
+
         return true;
     }
 
diff --git a/src/Channels/PresenceChannel.php b/src/Channels/PresenceChannel.php
index 3191be4c9d..614fe8da50 100644
--- a/src/Channels/PresenceChannel.php
+++ b/src/Channels/PresenceChannel.php
@@ -3,6 +3,8 @@
 namespace BeyondCode\LaravelWebSockets\Channels;
 
 use BeyondCode\LaravelWebSockets\DashboardLogger;
+use BeyondCode\LaravelWebSockets\Events\SubscribedToChannel;
+use BeyondCode\LaravelWebSockets\Events\UnsubscribedFromChannel;
 use BeyondCode\LaravelWebSockets\Server\Exceptions\InvalidSignature;
 use Ratchet\ConnectionInterface;
 use stdClass;
@@ -60,7 +62,7 @@ public function subscribe(ConnectionInterface $connection, stdClass $payload): b
                 // and in this case the events will only be triggered when the first tab is opened.
                 $this->channelManager
                     ->getMemberSockets($user->user_id, $connection->app->id, $this->getName())
-                    ->then(function ($sockets) use ($payload, $connection) {
+                    ->then(function ($sockets) use ($payload, $connection, $user) {
                         if (count($sockets) === 1) {
                             $memberAddedPayload = [
                                 'event' => 'pusher_internal:member_added',
@@ -72,6 +74,13 @@ public function subscribe(ConnectionInterface $connection, stdClass $payload): b
                                 (object) $memberAddedPayload, $connection->socketId,
                                 $connection->app->id
                             );
+
+                            SubscribedToChannel::dispatch(
+                                $connection->app->id,
+                                $connection->socketId,
+                                $this->getName(),
+                                $user
+                            );
                         }
 
                         DashboardLogger::log($connection->app->id, DashboardLogger::TYPE_SUBSCRIBED, [
@@ -128,6 +137,13 @@ public function unsubscribe(ConnectionInterface $connection): bool
                                         (object) $memberRemovedPayload, $connection->socketId,
                                         $connection->app->id
                                     );
+
+                                    UnsubscribedFromChannel::dispatch(
+                                        $connection->app->id,
+                                        $connection->socketId,
+                                        $this->getName(),
+                                        $user
+                                    );
                                 }
                             });
                     });
diff --git a/src/Events/ConnectionClosed.php b/src/Events/ConnectionClosed.php
new file mode 100644
index 0000000000..60b810be4c
--- /dev/null
+++ b/src/Events/ConnectionClosed.php
@@ -0,0 +1,38 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class ConnectionClosed
+{
+    use Dispatchable, SerializesModels;
+
+    /**
+     * The WebSockets app id that the user connected to.
+     *
+     * @var string
+     */
+    public $appId;
+
+    /**
+     * The Socket ID associated with the connection.
+     *
+     * @var string
+     */
+    public $socketId;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  string  $appId
+     * @param  string  $socketId
+     * @return void
+     */
+    public function __construct(string $appId, string $socketId)
+    {
+        $this->appId = $appId;
+        $this->socketId = $socketId;
+    }
+}
diff --git a/src/Events/ConnectionPonged.php b/src/Events/ConnectionPonged.php
new file mode 100644
index 0000000000..43440ebf64
--- /dev/null
+++ b/src/Events/ConnectionPonged.php
@@ -0,0 +1,38 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class ConnectionPonged
+{
+    use Dispatchable, SerializesModels;
+
+    /**
+     * The WebSockets app id that the user connected to.
+     *
+     * @var string
+     */
+    public $appId;
+
+    /**
+     * The Socket ID associated with the connection.
+     *
+     * @var string
+     */
+    public $socketId;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  string  $appId
+     * @param  string  $socketId
+     * @return void
+     */
+    public function __construct(string $appId, string $socketId)
+    {
+        $this->appId = $appId;
+        $this->socketId = $socketId;
+    }
+}
diff --git a/src/Events/NewConnection.php b/src/Events/NewConnection.php
new file mode 100644
index 0000000000..5c8a30fe46
--- /dev/null
+++ b/src/Events/NewConnection.php
@@ -0,0 +1,38 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class NewConnection
+{
+    use Dispatchable, SerializesModels;
+
+    /**
+     * The WebSockets app id that the user connected to.
+     *
+     * @var string
+     */
+    public $appId;
+
+    /**
+     * The Socket ID associated with the connection.
+     *
+     * @var string
+     */
+    public $socketId;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  string  $appId
+     * @param  string  $socketId
+     * @return void
+     */
+    public function __construct(string $appId, string $socketId)
+    {
+        $this->appId = $appId;
+        $this->socketId = $socketId;
+    }
+}
diff --git a/src/Events/SubscribedToChannel.php b/src/Events/SubscribedToChannel.php
new file mode 100644
index 0000000000..b3109f7f89
--- /dev/null
+++ b/src/Events/SubscribedToChannel.php
@@ -0,0 +1,57 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+use stdClass;
+
+class SubscribedToChannel
+{
+    use Dispatchable, SerializesModels;
+
+    /**
+     * The WebSockets app id that the user connected to.
+     *
+     * @var string
+     */
+    public $appId;
+
+    /**
+     * The Socket ID associated with the connection.
+     *
+     * @var string
+     */
+    public $socketId;
+
+    /**
+     * The channel name.
+     *
+     * @var string
+     */
+    public $channelName;
+
+    /**
+     * The user received on presence channel.
+     *
+     * @var string
+     */
+    public $user;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  string  $appId
+     * @param  string  $socketId
+     * @param  string  $channelName
+     * @param  stdClass|null  $user
+     * @return void
+     */
+    public function __construct(string $appId, string $socketId, string $channelName, ?stdClass $user = null)
+    {
+        $this->appId = $appId;
+        $this->socketId = $socketId;
+        $this->channelName = $channelName;
+        $this->user = $user;
+    }
+}
diff --git a/src/Events/UnsubscribedFromChannel.php b/src/Events/UnsubscribedFromChannel.php
new file mode 100644
index 0000000000..6e132e74b1
--- /dev/null
+++ b/src/Events/UnsubscribedFromChannel.php
@@ -0,0 +1,57 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+use stdClass;
+
+class UnsubscribedFromChannel
+{
+    use Dispatchable, SerializesModels;
+
+    /**
+     * The WebSockets app id that the user connected to.
+     *
+     * @var string
+     */
+    public $appId;
+
+    /**
+     * The Socket ID associated with the connection.
+     *
+     * @var string
+     */
+    public $socketId;
+
+    /**
+     * The channel name.
+     *
+     * @var string
+     */
+    public $channelName;
+
+    /**
+     * The user received on presence channel.
+     *
+     * @var string
+     */
+    public $user;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  string  $appId
+     * @param  string  $socketId
+     * @param  string  $channelName
+     * @param  stdClass|null  $user
+     * @return void
+     */
+    public function __construct(string $appId, string $socketId, string $channelName, ?stdClass $user = null)
+    {
+        $this->appId = $appId;
+        $this->socketId = $socketId;
+        $this->channelName = $channelName;
+        $this->user = $user;
+    }
+}
diff --git a/src/Events/WebSocketMessageReceived.php b/src/Events/WebSocketMessageReceived.php
new file mode 100644
index 0000000000..442ecb7bba
--- /dev/null
+++ b/src/Events/WebSocketMessageReceived.php
@@ -0,0 +1,56 @@
+<?php
+
+namespace BeyondCode\LaravelWebSockets\Events;
+
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+use Ratchet\RFC6455\Messaging\MessageInterface;
+
+class WebSocketMessageReceived
+{
+    use Dispatchable, SerializesModels;
+
+    /**
+     * The WebSockets app id that the user connected to.
+     *
+     * @var string
+     */
+    public $appId;
+
+    /**
+     * The Socket ID associated with the connection.
+     *
+     * @var string
+     */
+    public $socketId;
+
+    /**
+     * The message received.
+     *
+     * @var MessageInterface
+     */
+    public $message;
+
+    /**
+     * The decoded message as array.
+     *
+     * @var array
+     */
+    public $decodedMessage;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  string  $appId
+     * @param  string  $socketId
+     * @param  MessageInterface  $message
+     * @return void
+     */
+    public function __construct(string $appId, string $socketId, MessageInterface $message)
+    {
+        $this->appId = $appId;
+        $this->socketId = $socketId;
+        $this->message = $message;
+        $this->decodedMessage = json_decode($message->getPayload(), true);
+    }
+}
diff --git a/src/Server/Messages/PusherChannelProtocolMessage.php b/src/Server/Messages/PusherChannelProtocolMessage.php
index 6385d90834..c6f4f13472 100644
--- a/src/Server/Messages/PusherChannelProtocolMessage.php
+++ b/src/Server/Messages/PusherChannelProtocolMessage.php
@@ -2,6 +2,7 @@
 
 namespace BeyondCode\LaravelWebSockets\Server\Messages;
 
+use BeyondCode\LaravelWebSockets\Events\ConnectionPonged;
 use Illuminate\Support\Str;
 use Ratchet\ConnectionInterface;
 use stdClass;
@@ -35,6 +36,8 @@ protected function ping(ConnectionInterface $connection)
             ->connectionPonged($connection)
             ->then(function () use ($connection) {
                 $connection->send(json_encode(['event' => 'pusher:pong']));
+
+                ConnectionPonged::dispatch($connection->app->id, $connection->socketId);
             });
     }
 
diff --git a/src/Server/WebSocketHandler.php b/src/Server/WebSocketHandler.php
index 9fd3fe2d4d..8bec3895a8 100644
--- a/src/Server/WebSocketHandler.php
+++ b/src/Server/WebSocketHandler.php
@@ -5,6 +5,9 @@
 use BeyondCode\LaravelWebSockets\Apps\App;
 use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
 use BeyondCode\LaravelWebSockets\DashboardLogger;
+use BeyondCode\LaravelWebSockets\Events\ConnectionClosed;
+use BeyondCode\LaravelWebSockets\Events\NewConnection;
+use BeyondCode\LaravelWebSockets\Events\WebSocketMessageReceived;
 use BeyondCode\LaravelWebSockets\Facades\StatisticsCollector;
 use Exception;
 use Ratchet\ConnectionInterface;
@@ -63,6 +66,8 @@ public function onOpen(ConnectionInterface $connection)
                 'origin' => "{$request->getUri()->getScheme()}://{$request->getUri()->getHost()}",
                 'socketId' => $connection->socketId,
             ]);
+
+            NewConnection::dispatch($connection->app->id, $connection->socketId);
         }
     }
 
@@ -84,6 +89,12 @@ public function onMessage(ConnectionInterface $connection, MessageInterface $mes
         )->respond();
 
         StatisticsCollector::webSocketMessage($connection->app->id);
+
+        WebSocketMessageReceived::dispatch(
+            $connection->app->id,
+            $connection->socketId,
+            $message
+        );
     }
 
     /**
@@ -105,6 +116,8 @@ public function onClose(ConnectionInterface $connection)
                     DashboardLogger::log($connection->app->id, DashboardLogger::TYPE_DISCONNECTED, [
                         'socketId' => $connection->socketId,
                     ]);
+
+                    ConnectionClosed::dispatch($connection->app->id, $connection->socketId);
                 }
             });
     }