diff --git a/Connection.php b/Connection.php index fcf6897..bf6ff6a 100644 --- a/Connection.php +++ b/Connection.php @@ -102,7 +102,7 @@ class Connection extends Component */ public function init(): void { - $this->eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 0); + $this->eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 9999); $this->eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0); $this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0); $this->eventProvider->on(Commit::class, [$this, 'commit'], 0); diff --git a/DatabasesProviders.php b/DatabasesProviders.php index c630761..d94ce04 100644 --- a/DatabasesProviders.php +++ b/DatabasesProviders.php @@ -48,7 +48,7 @@ class DatabasesProviders extends Providers } $this->provider->on(OnWorkerStart::class, [$this, 'check']); $this->provider->on(OnTaskerStart::class, [$this, 'check']); - $this->provider->on(OnWorkerExit::class, [$this, 'exit']); + $this->provider->on(OnWorkerExit::class, [$this, 'exit'], 9999); foreach ($databases as $key => $database) { $application->set($key, $this->_settings($database)); }