From ae244757a2536bdda739c79764bf2d3c410939b0 Mon Sep 17 00:00:00 2001
From: Ben Walch <bwalch@dachcom.ch>
Date: Wed, 17 Apr 2024 13:33:23 +0200
Subject: [PATCH] fixed messenger auto setup (#87)

---
 src/Queue/Transport/ExtendedDoctrineConnection.php | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/src/Queue/Transport/ExtendedDoctrineConnection.php b/src/Queue/Transport/ExtendedDoctrineConnection.php
index c77bb99..e4bd65d 100644
--- a/src/Queue/Transport/ExtendedDoctrineConnection.php
+++ b/src/Queue/Transport/ExtendedDoctrineConnection.php
@@ -45,6 +45,19 @@ public function setup(): void
         $this->autoSetup = false;
     }
 
+    public function configureSchema(Schema $schema, DBALConnection $forConnection, \Closure $isSameDatabase): void
+    {
+        if ($schema->hasTable($this->configuration['table_name'])) {
+            return;
+        }
+
+        if ($forConnection !== $this->driverConnection && !$isSameDatabase($this->executeStatement(...))) {
+            return;
+        }
+
+        $this->addTableToSchema($schema);
+    }
+
     public function get(): ?array
     {
         if ($this->driverConnection->getDatabasePlatform() instanceof MySQLPlatform) {