diff --git a/src/Events/Concerns/Dispatchable.php b/src/Events/Concerns/Dispatchable.php
new file mode 100644
index 00000000..a9336a8b
--- /dev/null
+++ b/src/Events/Concerns/Dispatchable.php
@@ -0,0 +1,22 @@
+<?php
+
+namespace Laravel\Reverb\Events\Concerns;
+
+use Laravel\Reverb\Loggers\Log;
+
+trait Dispatchable
+{
+    /**
+     * Dispatch the event with the given arguments.
+     *
+     * @return mixed
+     */
+    public static function dispatch()
+    {
+        try {
+            return event(new static(...func_get_args()));
+        } catch (\Exception $exception) {
+            Log::error($exception->getMessage());
+        }
+    }
+}
diff --git a/src/Events/ConnectionClosed.php b/src/Events/ConnectionClosed.php
new file mode 100644
index 00000000..1bf4365c
--- /dev/null
+++ b/src/Events/ConnectionClosed.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\Concerns\Dispatchable;
+
+class ConnectionClosed
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(public Connection $connection)
+    {
+        //
+    }
+}
diff --git a/src/Events/ConnectionError.php b/src/Events/ConnectionError.php
new file mode 100644
index 00000000..9ca7b423
--- /dev/null
+++ b/src/Events/ConnectionError.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\Concerns\Dispatchable;
+
+class ConnectionError
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(public Connection $connection, public \Exception $exception)
+    {
+        //
+    }
+}
diff --git a/src/Events/MessageReceived.php b/src/Events/MessageReceived.php
index 8aedf673..6d4c936a 100644
--- a/src/Events/MessageReceived.php
+++ b/src/Events/MessageReceived.php
@@ -2,8 +2,8 @@
 
 namespace Laravel\Reverb\Events;
 
-use Illuminate\Foundation\Events\Dispatchable;
 use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\Concerns\Dispatchable;
 
 class MessageReceived
 {
diff --git a/src/Events/MessageSent.php b/src/Events/MessageSent.php
index 34e23936..6ce4ee38 100644
--- a/src/Events/MessageSent.php
+++ b/src/Events/MessageSent.php
@@ -2,8 +2,8 @@
 
 namespace Laravel\Reverb\Events;
 
-use Illuminate\Foundation\Events\Dispatchable;
 use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\Concerns\Dispatchable;
 
 class MessageSent
 {
diff --git a/src/Events/NewConnection.php b/src/Events/NewConnection.php
new file mode 100644
index 00000000..c443a4aa
--- /dev/null
+++ b/src/Events/NewConnection.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\Concerns\Dispatchable;
+
+class NewConnection
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(public Connection $connection)
+    {
+        //
+    }
+}
diff --git a/src/Events/ServerStarted.php b/src/Events/ServerStarted.php
new file mode 100644
index 00000000..6c7fee2d
--- /dev/null
+++ b/src/Events/ServerStarted.php
@@ -0,0 +1,18 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Laravel\Reverb\Events\Concerns\Dispatchable;
+
+class ServerStarted
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct()
+    {
+        //
+    }
+}
diff --git a/src/Events/ServerStopped.php b/src/Events/ServerStopped.php
new file mode 100644
index 00000000..2f185b71
--- /dev/null
+++ b/src/Events/ServerStopped.php
@@ -0,0 +1,18 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Laravel\Reverb\Events\Concerns\Dispatchable;
+
+class ServerStopped
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct()
+    {
+        //
+    }
+}
diff --git a/src/Events/SubscribedToChannel.php b/src/Events/SubscribedToChannel.php
new file mode 100644
index 00000000..b0d3a3f9
--- /dev/null
+++ b/src/Events/SubscribedToChannel.php
@@ -0,0 +1,22 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\Concerns\Dispatchable;
+
+class SubscribedToChannel
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(
+        public Connection $connection,
+        public string $channelName,
+        public ?string $auth = null,
+    ) {
+        //
+    }
+}
diff --git a/src/Events/UnsubscribedFromChannel.php b/src/Events/UnsubscribedFromChannel.php
new file mode 100644
index 00000000..cb7d3fad
--- /dev/null
+++ b/src/Events/UnsubscribedFromChannel.php
@@ -0,0 +1,21 @@
+<?php
+
+namespace Laravel\Reverb\Events;
+
+use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\Concerns\Dispatchable;
+
+class UnsubscribedFromChannel
+{
+    use Dispatchable;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(
+        public Connection $connection,
+        public string $channelName,
+    ) {
+        //
+    }
+}
diff --git a/src/Protocols/Pusher/Channels/Channel.php b/src/Protocols/Pusher/Channels/Channel.php
index 4d6c75aa..6140d676 100644
--- a/src/Protocols/Pusher/Channels/Channel.php
+++ b/src/Protocols/Pusher/Channels/Channel.php
@@ -3,6 +3,8 @@
 namespace Laravel\Reverb\Protocols\Pusher\Channels;
 
 use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\SubscribedToChannel;
+use Laravel\Reverb\Events\UnsubscribedFromChannel;
 use Laravel\Reverb\Protocols\Pusher\Concerns\SerializesChannels;
 use Laravel\Reverb\Protocols\Pusher\Contracts\ChannelConnectionManager;
 use Laravel\Reverb\Protocols\Pusher\Contracts\ChannelManager;
@@ -66,6 +68,8 @@ public function findById(string $id): ?Connection
     public function subscribe(Connection $connection, ?string $auth = null, ?string $data = null): void
     {
         $this->connections->add($connection, $data ? json_decode($data, true) : []);
+
+        SubscribedToChannel::dispatch($connection, $this->name(), $auth);
     }
 
     /**
@@ -78,6 +82,8 @@ public function unsubscribe(Connection $connection): void
         if ($this->connections->isEmpty()) {
             app(ChannelManager::class)->for($connection->app())->remove($this);
         }
+
+        UnsubscribedFromChannel::dispatch($connection, $this->name());
     }
 
     /**
diff --git a/src/Protocols/Pusher/Server.php b/src/Protocols/Pusher/Server.php
index c7caf71c..f8b83fca 100644
--- a/src/Protocols/Pusher/Server.php
+++ b/src/Protocols/Pusher/Server.php
@@ -5,7 +5,10 @@
 use Exception;
 use Illuminate\Support\Str;
 use Laravel\Reverb\Contracts\Connection;
+use Laravel\Reverb\Events\ConnectionClosed;
+use Laravel\Reverb\Events\ConnectionError;
 use Laravel\Reverb\Events\MessageReceived;
+use Laravel\Reverb\Events\NewConnection;
 use Laravel\Reverb\Loggers\Log;
 use Laravel\Reverb\Protocols\Pusher\Contracts\ChannelManager;
 use Laravel\Reverb\Protocols\Pusher\Exceptions\InvalidOrigin;
@@ -34,6 +37,8 @@ public function open(Connection $connection): void
             $this->handler->handle($connection, 'pusher:connection_established');
 
             Log::info('Connection Established', $connection->id());
+
+            NewConnection::dispatch($connection);
         } catch (Exception $e) {
             $this->error($connection, $e);
         }
@@ -82,6 +87,8 @@ public function close(Connection $connection): void
         $connection->disconnect();
 
         Log::info('Connection Closed', $connection->id());
+
+        ConnectionClosed::dispatch($connection);
     }
 
     /**
@@ -93,21 +100,21 @@ public function error(Connection $connection, Exception $exception): void
             $connection->send(json_encode($exception->payload()));
 
             Log::error('Message from '.$connection->id().' resulted in a pusher error');
-            Log::info($exception->getMessage());
-
-            return;
+        } else {
+            $connection->send(json_encode([
+                'event' => 'pusher:error',
+                'data' => json_encode([
+                    'code' => 4200,
+                    'message' => 'Invalid message format',
+                ]),
+            ]));
+
+            Log::error('Message from '.$connection->id().' resulted in an unknown error');
         }
 
-        $connection->send(json_encode([
-            'event' => 'pusher:error',
-            'data' => json_encode([
-                'code' => 4200,
-                'message' => 'Invalid message format',
-            ]),
-        ]));
-
-        Log::error('Message from '.$connection->id().' resulted in an unknown error');
         Log::info($exception->getMessage());
+
+        ConnectionError::dispatch($connection, $exception);
     }
 
     /**
diff --git a/src/Servers/Reverb/Console/Commands/StartServer.php b/src/Servers/Reverb/Console/Commands/StartServer.php
index 79807bfc..f23920fe 100644
--- a/src/Servers/Reverb/Console/Commands/StartServer.php
+++ b/src/Servers/Reverb/Console/Commands/StartServer.php
@@ -7,6 +7,8 @@
 use Laravel\Reverb\Application;
 use Laravel\Reverb\Contracts\ApplicationProvider;
 use Laravel\Reverb\Contracts\Logger;
+use Laravel\Reverb\Events\ServerStarted;
+use Laravel\Reverb\Events\ServerStopped;
 use Laravel\Reverb\Jobs\PingInactiveConnections;
 use Laravel\Reverb\Jobs\PruneStaleConnections;
 use Laravel\Reverb\Loggers\CliLogger;
@@ -68,6 +70,8 @@ public function handle(): void
         $this->components->info('Starting '.($server->isSecure() ? 'secure ' : '')."server on {$host}:{$port}".(($hostname && $hostname !== $host) ? " ({$hostname})" : ''));
 
         $server->start();
+
+        ServerStarted::dispatch();
     }
 
     /**
@@ -108,6 +112,8 @@ protected function ensureRestartCommandIsRespected(Server $server, LoopInterface
 
             $server->stop();
 
+            ServerStopped::dispatch();
+
             $this->components->info("Stopping server on {$host}:{$port}");
         });
     }