NotifierQueueTask.php

<?php

namespace Bow\Notifier;

use Bow\Database\Barry\Model;
use Bow\Queue\QueueTask;
use Throwable;

class NotifierQueueTask extends QueueTask
{
    /**
     * The message bag
     *
     * @var array
     */
    private array $bags = [];

    /**
     * NotifierQueueTask constructor
     *
     * @param Model     $context
     * @param Notifier $notifier
     */
    public function __construct(
        Model $context,
        Notifier $notifier,
    ) {
        $this->bags = [
            "notifier" => $notifier,
            "context" => $context,
        ];
    }

    /**
     * Process mail
     *
     * @return void
     */
    public function process(): void
    {
        $notifier = $this->bags['notifier'];
        $notifier->process($this->bags['context']);
    }

    /**
     * Send the processing exception
     *
     * @param  Throwable $e
     * @return void
     */
    public function onException(Throwable $e): void
    {
        $this->deleteTask();
    }
}