Creating your own task

Baking new Queue task and test

You can bake a new task and its test via

bin/cake bake queue_task MyTaskName [-p PluginName]

It will generate a MyTaskNameTask class in the right namespace.

It will not overwrite existing classes unless you explicitly force this (after prompting).

You can use My/Sub/MyTaskNameTask to create tasks in sub-namespaces.

Detailed explanation

In most cases you wouldn't want to use the existing task, but just quickly build your own. Put it into src/Queue/Task/ as {YourNameForIt}Task.php.

You need to at least implement the run() method:

namespace App\Queue\Task;

use Queue\Queue\Task;
use RuntimeException;

class YourNameForItTask extends Task {

    /**
     * Timeout in seconds for this specific task.
     * Automatically capped to defaultRequeueTimeout if higher.
     *
     * @var ?int
     */
    public ?int $timeout = 20;

    /**
     * Number of retries for this task if it fails.
     *
     * @var ?int
     */
    public ?int $retries = 1;

    /**
     * @param array $data The array passed to QueuedJobsTable::createJob()
     * @param int $jobId The id of the QueuedJob entity
     * @return void
     */
    public function run(array $data, int $jobId): void {
        $fooBarsTable = $this->fetchTable('FooBars');
        if (!$fooBarsTable->doSth()) {
            throw new RuntimeException('Couldnt do sth.');
        }
    }

}

Make sure it throws an exception with a clear error message in case of failure.

Note: You can use the provided Queue\Model\QueueException if you do not need to include a stack trace. This is usually the default inside custom tasks.

DI Container Example

If you use the Dependency Injection Container provided by CakePHP you can also use it inside your tasks.

use Queue\Queue\ServicesTrait;

class MyCustomTask extends Task {

    use ServicesTrait;

    public function run(array $data, int $jobId): void {
        $myService = $this->getService(MyService::class);
    }
}

As you see here you have to add the ServicesTrait to your task which then allows you to use the $this->getService() method.

Organize tasks in sub folders

You can group tasks in sub namespaces. E.g. src/Queue/Task/My/Sub/{YourNameForIt}Task.php would be found and used as My/Sub/{YourNameForIt}.