addressing some comments
This commit is contained in:
parent
55dfb0b034
commit
e8dbd043ec
|
@ -18,7 +18,6 @@ class Database extends Event
|
||||||
{
|
{
|
||||||
parent::__construct($connection);
|
parent::__construct($connection);
|
||||||
|
|
||||||
$this->setQueue($this->getProject()->getAttribute('database'));
|
|
||||||
$this->setClass(Event::DATABASE_CLASS_NAME);
|
$this->setClass(Event::DATABASE_CLASS_NAME);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -110,6 +109,8 @@ class Database extends Event
|
||||||
public function trigger(): string|bool
|
public function trigger(): string|bool
|
||||||
{
|
{
|
||||||
|
|
||||||
|
$this->setQueue($this->getProject()->getAttribute('database'));
|
||||||
|
|
||||||
$client = new Client($this->queue, $this->connection);
|
$client = new Client($this->queue, $this->connection);
|
||||||
|
|
||||||
return $client->enqueue([
|
return $client->enqueue([
|
||||||
|
|
|
@ -38,8 +38,6 @@ class Schedule extends Action
|
||||||
->inject('dbForConsole')
|
->inject('dbForConsole')
|
||||||
->inject('getProjectDB')
|
->inject('getProjectDB')
|
||||||
->callback(fn (Group $pools, Database $dbForConsole, callable $getProjectDB) => $this->action($pools, $dbForConsole, $getProjectDB));
|
->callback(fn (Group $pools, Database $dbForConsole, callable $getProjectDB) => $this->action($pools, $dbForConsole, $getProjectDB));
|
||||||
|
|
||||||
throw new Exception('error on Schedule cli');
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in a new issue