fixed messenger auto setup (#87)

dachcom-digital · Apr 17, 2024 · ae24475 · ae24475
1 parent da046ad
commit ae24475
Showing 1 changed file with 13 additions and 0 deletions.
diff --git 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) {