diff --git a/src/Listeners/UseCentralConnection.php b/src/Listeners/UseCentralConnection.php
new file mode 100644
index 00000000..17d17863
--- /dev/null
+++ b/src/Listeners/UseCentralConnection.php
@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Stancl\Tenancy\Listeners;
+
+use Illuminate\Foundation\Application;
+use Stancl\Tenancy\Database\DatabaseManager;
+use Stancl\Tenancy\Events\Contracts\TenancyEvent;
+
+class UseCentralConnection
+{
+    public function __construct(
+        protected DatabaseManager $database,
+        protected Application $app
+    ) {
+    }
+
+    public function handle(TenancyEvent $event): void
+    {
+        $this->database->purgeTenantConnection();
+        $this->database->setDefaultConnection($this->app['config']->get('tenancy.database.central_connection'));
+    }
+}
diff --git a/src/Listeners/UseTenantConnection.php b/src/Listeners/UseTenantConnection.php
new file mode 100644
index 00000000..a4c12108
--- /dev/null
+++ b/src/Listeners/UseTenantConnection.php
@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Stancl\Tenancy\Listeners;
+
+use Stancl\Tenancy\Database\DatabaseManager;
+use Stancl\Tenancy\Events\Contracts\TenancyEvent;
+
+class UseTenantConnection
+{
+    public function __construct(
+        protected DatabaseManager $database,
+    ) {
+    }
+
+    public function handle(TenancyEvent $event): void
+    {
+        $this->database->setDefaultConnection('tenant');
+    }
+}