sinevia / php-library-sqldb-tasks
There is no license information available for the latest version (v1.5.0) of this package.
PHP SqlDb Tasks
v1.5.0
2019-06-22 09:31 UTC
Requires
- sinevia/php-library-sqldb: >=v3.6.2
- sinevia/php-library-uid: >=v1.0.0
Requires (Dev)
- bafs/testify: ^1.0
README
Persistent task queue for SqlDb.
Features
- Asynchronious (multiple threads/processes) or synchronious (sigle thread/process) execution
- Instantant (by the code creating the task) or queued for execution by another process
- Full details logged
- Inspectable, debuggable
- Re-runnable
How it works?
-
Tasks. Tasks are defined in the task table. Each task defines a handler class. The handler class has a method handle($parameters), which processes teh task and returns true on success, false otherwise.
-
Queue. The tasks to be processed are added to the queued table with its parameters. Each task is then sequentially processed, by calling the handle methdod of its handler which also receives the parameters. Depending on the result the queued task is marked as completed on success, failed otherwise.
Quick Example
$task = \Sinevia\Tasks\Task::queue('\App\Tasks\PaypalOrderTask', $parametersArray); if ($task == null){ logger()->error('Task "\App\Tasks\PaypalOrderTask" failed to be created', $parametersArray); return false; } $result = \Sinevia\Tasks\Queue::processQueuedTaskById($task->get('Id')); return $result;
Task Handlers
class HelloWorldTask extends \Sinevia\Tasks\BaseHandler {
function handle(array $parameters){
$this->queuedTask->addDetails('Adding Hello World to Output Parameters');
$this->queuedTask->setOutputKey('hello','world');
return true;
}
}