modify plugin name
This commit is contained in:
+1
-1
@@ -102,7 +102,7 @@ class Connection extends Component
|
|||||||
*/
|
*/
|
||||||
public function init(): void
|
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(BeginTransaction::class, [$this, 'beginTransaction'], 0);
|
||||||
$this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
|
$this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
|
||||||
$this->eventProvider->on(Commit::class, [$this, 'commit'], 0);
|
$this->eventProvider->on(Commit::class, [$this, 'commit'], 0);
|
||||||
|
|||||||
@@ -48,7 +48,7 @@ class DatabasesProviders extends Providers
|
|||||||
}
|
}
|
||||||
$this->provider->on(OnWorkerStart::class, [$this, 'check']);
|
$this->provider->on(OnWorkerStart::class, [$this, 'check']);
|
||||||
$this->provider->on(OnTaskerStart::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) {
|
foreach ($databases as $key => $database) {
|
||||||
$application->set($key, $this->_settings($database));
|
$application->set($key, $this->_settings($database));
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user