1
0
Fork 0
mirror of synced 2024-06-14 00:34:51 +12:00

Messaging

This commit is contained in:
shimon 2023-05-30 16:19:44 +03:00
parent 478e83a4bf
commit 73f3f0aee6

View file

@ -12,8 +12,6 @@ use Utopia\Queue\Message;
class Audits extends Action
{
protected static array $init;
public static function getName(): string
{
return 'audits';
@ -25,10 +23,12 @@ class Audits extends Action
->desc('Audits worker')
->inject('message')
->inject('dbForProject')
->callback(fn ($message, $dbForProject) => $this->action($message, $dbForProject));
->inject('polls')
->callback(fn ($message, $dbForProject, $pools) => $this->action($message, $dbForProject, $pools));
}
public function action(Message $message, $dbForProject): void
{