Fix queue getDriver()

asika32764 · asika32764 · commit d8dd5488dd7a · 2026-03-15T00:17:38.000+08:00
diff --git a/packages/queue/src/Driver/DatabaseQueueDriver.php b/packages/queue/src/Driver/DatabaseQueueDriver.php
@@ -107,7 +107,7 @@ function () use ($now, $query) {
                 try {
                     $data = $this->db->prepare($query)->get();
                 } catch (\Exception $e) {
-                    if ($this->db->driver::shouldAutoReconnect($e)) {
+                    if ($this->db->getDriver()::shouldAutoReconnect($e)) {
                         // DB should already auto reconnect, if reconnect failed, we force queue restart.
                         UnrecoverableException::throwFrom($e);
                     }

Original file line number	Diff line number	Diff line change
`@@ -107,7 +107,7 @@ function () use ($now, $query) {`
`107`	`107`	`try {`
`108`	`108`	`$data = $this->db->prepare($query)->get();`
`109`	`109`	`} catch (\Exception $e) {`
`110`		`- if ($this->db->driver::shouldAutoReconnect($e)) {`
	`110`	`+ if ($this->db->getDriver()::shouldAutoReconnect($e)) {`
`111`	`111`	`// DB should already auto reconnect, if reconnect failed, we force queue restart.`
`112`	`112`	`UnrecoverableException::throwFrom($e);`
`113`	`113`	`}`