1
0
Fork 0
mirror of synced 2024-06-26 10:10:57 +12:00

fix pool is empty webhook worker

This commit is contained in:
Matej Bačo 2024-01-18 09:13:11 +00:00
parent c9cd4c126c
commit 2be504ed8a
2 changed files with 5 additions and 1 deletions

View file

@ -240,7 +240,10 @@ $worker
->inject('error')
->inject('logger')
->inject('log')
->action(function (Throwable $error, ?Logger $logger, Log $log) use ($queueName) {
->inject('pools')
->action(function (Throwable $error, ?Logger $logger, Log $log, Group $pools) use ($queueName) {
$pools->reclaim();
$version = App::getEnv('_APP_VERSION', 'UNKNOWN');
if ($error instanceof PDOException) {

View file

@ -49,6 +49,7 @@ class Webhooks extends Action
*/
public function action(Message $message, Database $dbForConsole, Mail $queueForMails, Log $log): void
{
$this->errors = [];
$payload = $message->getPayload() ?? [];
if (empty($payload)) {