PHPackages                             tomatom/jobqueuebundle - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Queues & Workers](/categories/queues)
4. /
5. tomatom/jobqueuebundle

ActiveSymfony-bundle[Queues & Workers](/categories/queues)

tomatom/jobqueuebundle
======================

JMSJobQueueBundle alternative for Symfony 6+ with browser interface

v2.0.9(5mo ago)67.8k↓42.4%3[1 issues](https://github.com/TomAtomCZ/JobQueueBundle/issues)MITPHPPHP >=8.1CI passing

Since Aug 16Pushed 3mo ago4 watchersCompare

[ Source](https://github.com/TomAtomCZ/JobQueueBundle)[ Packagist](https://packagist.org/packages/tomatom/jobqueuebundle)[ RSS](/packages/tomatom-jobqueuebundle/feed)WikiDiscussions main Synced 1mo ago

READMEChangelog (10)Dependencies (15)Versions (25)Used By (0)

JobQueueBundle
==============

[](#jobqueuebundle)

### Symfony bundle which aims to replace JMSJobQueueBundle for scheduling console commands, with complete browser interface.

[](#symfony-bundle-which-aims-to-replace-jmsjobqueuebundle-for-scheduling-console-commands-with-complete-browser-interface)

Table of Contents
-----------------

[](#table-of-contents)

1. [Features](#features)
2. [Installation](#installation)
3. [Configuration](#configuration)
    - [Bundles](#configbundlesphp)
    - [Routes](#configroutesyaml)
    - [Messenger](#configpackagesmessengeryaml)
    - [Security](#configpackagessecurityyaml)
    - [Job Queue](#configpackagesjob_queueyaml)
4. [Usage](#usage)
    - [Job Types](#types-of-ways-jobs-can-be-run)
    - [Creating Jobs Programmatically](#manually-creating-the-jobs-in-your-application)
    - [Creating Jobs via Browser](#creating-jobs-via-the-browser-interface)
5. [Testing](#testing)
6. [Dependencies](#dependencies)
7. [TODO](#todo)
8. [Additional info / Contributing](#additional-info--contributing)

Features
--------

[](#features)

- Schedule any command from your app as a server-side job, either programmatically or through a browser interface.
- Run jobs right away, postpone them or make them recurring.
- Browse jobs and see their details in browser.
- Cancel and retry jobs.
- Add related entity and parent job.
- Capture and store specific output from commands in the job's output parameters.

Installation
------------

[](#installation)

```
composer require tomatom/jobqueuebundle

```

Configuration
-------------

[](#configuration)

#### config/bundles.php:

[](#configbundlesphp)

```
TomAtom\JobQueueBundle\JobQueueBundle::class => ['all' => true]
```

---

#### config/routes.yaml:

[](#configroutesyaml)

```
job_queue:
  resource: "@JobQueueBundle/src/Controller/"
  type: attribute
```

---

#### config/packages/messenger.yaml:

[](#configpackagesmessengeryaml)

You can create your own transport for the job messages - or just use *async* transport

```
framework:
  messenger:
    # Your messenger config
    transports:
    # Your other transports
    job_message:
      dsn: "%env(MESSENGER_TRANSPORT_DSN)%"
      options:
        queue_name: job_message
    routing:
      TomAtom\JobQueueBundle\Message\JobMessage: job_message # or async
```

---

#### config/packages/security.yaml:

[](#configpackagessecurityyaml)

The bundle uses the role security system to control access for the jobs/command scheduling. You can assign roles based on the level of access you want to grant to each user.

Available roles are:

**ROLE\_JQB\_ALL** - The main role with full permissions. Provides unrestricted access to all features of the bundle.

**ROLE\_JQB\_JOBS** - Grants full permissions for jobs (JOB\_ roles).

**ROLE\_JQB\_COMMANDS** - Grants full permissions for command scheduling (COMMAND\_ roles).

**ROLE\_JQB\_JOB\_LIST** - Allows access to view the job list.

**ROLE\_JQB\_JOB\_READ** - Allows access to view job details.

**ROLE\_JQB\_JOB\_CREATE** - Allows creating new jobs.

**ROLE\_JQB\_JOB\_DELETE** - Allows deleting jobs.

**ROLE\_JQB\_JOB\_CANCEL** - Allows canceling jobs.

**ROLE\_JQB\_COMMAND\_SCHEDULE** - Allows scheduling commands.

(Also with constants in [JobQueuePermissions.php](src/Security/JobQueuePermissions.php))

To grant full access to users, add **ROLE\_JQB\_ALL** to the role hierarchy:

```
security:
  role_hierarchy:
    ROLE_ADMIN:
      - ROLE_JQB_ALL
```

To restrict access for example to only viewing the job list and job details (without creation or scheduling), configure the roles like this:

```
security:
  role_hierarchy:
    ROLE_USER:
      - ROLE_JQB_JOB_LIST
      - ROLE_JQB_JOB_READ
```

#### Note - jobs creation is always possible where security has no loaded user, for example if created in a command.

[](#note---jobs-creation-is-always-possible-where-security-has-no-loaded-user-for-example-if-created-in-a-command)

---

#### config/packages/job\_queue.yaml:

[](#configpackagesjob_queueyaml)

You do not have to create this file for the bundle to work, but you can edit some parameters

```
job_queue:
  database:
    job_table_name: "your_job_table_name" # Default = job_queue
    job_recurring_table_name: "your_job_recurring_table_name" # Default = job_recurring_queue
  scheduling:
    heartbeat_interval: "1 hour" # Default = 1 minute
```

#### Update your database so the job tables are created

[](#update-your-database-so-the-job-tables-are-created)

```
php bin/console d:s:u --force
```

or via migrations.

#### Do not forget to run the messenger

[](#do-not-forget-to-run-the-messenger)

This is up to you and where your project runs, but you need to have the messenger consuming the right transport for the bundle to work.

```
php bin/console messenger:consume job_message
```

For recurring messages you also need the scheduler running so the jobs are created

```
php bin/console messenger:consume scheduler_job_recurring
```

Usage
-----

[](#usage)

#### Types of ways jobs can be run

[](#types-of-ways-jobs-can-be-run)

- **Once** - Runs once right after creation (Job entity)
- **Once postponed** - Runs once on given time (Job entity)
- **Recurring**
    - Runs repeatedly on time by the given [Symfony scheduler cron expression](https://symfony.com/doc/current/scheduler.html#cron-expression-triggers)(JobRecurring entity which creates new Job entity on every run)
    - Changes in the recurring jobs (adding/deleting/editing) are handled by the "heartbeat" message, which runs on the given interval (default is 1 minute but can be edited in the config file - if you do not add / edit them often, you can set it to higher value)

Once job is created, [Symfony messenger](https://symfony.com/doc/current/messenger.html) message is created which handles the run of the command from the job.

### Manually creating the jobs in your application:

[](#manually-creating-the-jobs-in-your-application)

The function **createCommandJob** from **CommandJobFactory** accepts:

- command name
- command parameters
- ID of related entity (optional)
- name of related entity class - (optional)
- job entity for parent job (optional)
- entity of recurring parent job (optional)
- datetime of postponed job start (optional)
- check user role (optional)

and returns the created job.

**Basic example**:

```
$commandName = 'app:your:command';

$params = [
    '--param1=' . $request->get('param1'),
    '--param2=' . $request->get('param2'),
];

// Try to create the command job
try {
    $job = $this->commandJobFactory->createCommandJob($commandName, $params);
} catch (OptimisticLockException|ORMException|CommandJobException $e) {
    // Redirect back upon failure
    $this->logger->error('createCommandJob error: ' . $e->getMessage());
    return $this->redirectToRoute('your_route');
}

// Redirect to the command job detail
return $this->redirectToRoute('job_queue_detail', ['id' => $job->getId()]);
```

**Adding a related entity**:

Purpose of this is to filter jobs seen in the list by the related entity.

For example, if you have a Customer entity:

```
$job = $this->commandJobFactory->createCommandJob($commandName, $params, $customer->getId(), Customer::class);
```

If you then go to the job list with parameters /job/list/**Customer**/**1** (which is being automatically added if going from the detail with related entity) or if you add it to the list path yourself like:

```
{{ 'job.job_list'|trans }}
```

then the job list only contains jobs for that given customer.

You can also only add the entity name to get all jobs for a given entity.

**Adding a parent job**:

Jobs can have another one as a parent job. One job can have multiple children jobs.

This can be used if for example you need to create a job that has to run after another job finishes.

(Recreating jobs also creates a new one with the original as a parent.)

```
// Retrieve another job entity to add as a parent job
$parentJob = $this->entityManager->getRepository(Job::class)->findOneBy(['command' => $command, 'status' => Job::STATUS_COMPLETED]);
$job = $this->commandJobFactory->createCommandJob($commandName, $params, null, null, $parentJob);
```

If jobs have any children/parent there will be button links to them in the job detail (for parents also in job list).

**Creating a postponed job**:

If you want to set a command to run once in given time - set $startAt of type DateTimeImmutable

```
$startAt = DateTimeImmutable::createFromFormat('Y-m-d\TH:i', $postponedDateTime);
$job = $commandJobFactory->createCommandJob($commandName, $params, $listId, $listName, null, null, $startAt);
```

**Creating / updating a recurring job**:

```
$jobRecurring = $this->entityManager->getRepository(JobRecurring::class)->find($id);
if ($jobRecurring) {
    $commandJobFactory->updateRecurringCommandJob($jobRecurring, $commandName, $params, $frequency, $active);
} else {
    $commandJobFactory->createRecurringCommandJob($commandName, $params, $frequency, $active);
}
```

Where both functions call the function **saveRecurringCommandJob** from **CommandJobFactory**, which accepts:

- job recurring - updated recurring job (only on updateRecurringCommandJob)
- command name
- command params
- frequency of type [Symfony scheduler cron expression](https://symfony.com/doc/current/scheduler.html#cron-expression-triggers)
- is active

**Saving values from the command output**:

If you need to retrieve and save any data from the output of a command that is running from a job, you can do that by adding anything after constant **Job::COMMAND\_OUTPUT\_PARAMS** in the command output, for example:

```
$io->info(Job::COMMAND_OUTPUT_PARAMS . $customerId) // $customerId = 123;
```

This will output in the console **OUTPUT PARAMS: 123** and the '123' will be saved in the job's **outputParams**, which can be then used for example to retrieve the customer entity.

```
$customer = $this->entityManager->getRepository(Customer::class)->find($job->getOutputParams());
```

Output params are saved in the database as a TEXT and you can save multiple values, which are then separated by a comma, for example:

```
$io->info(Job::COMMAND_OUTPUT_PARAMS . 123);
$io->info(Job::COMMAND_OUTPUT_PARAMS . 'some text value');
$io->info(Job::COMMAND_OUTPUT_PARAMS . implode(['a', 'b']));
```

this will be saved as '123, some text value, ab' and then you need to individually handle getting the values by what you've saved.

### Creating jobs via the browser interface:

[](#creating-jobs-via-the-browser-interface)

Available urls:

- **command/schedule** - Create a command to run as job
- **command/schedule/{id}** - Edit recurring job
- **job/list/{name}/{id}** - List jobs (related entity name+id)
- **job/recurring/list** - List recurring jobs
- **job/{id}** - Job detail with command output

Schedule CommandJob ListJob Detail[![Schedule Command](docs/img_schedule_command.png)](docs/img_schedule_command.png)[![Job List](docs/img_job_list.png)](docs/img_job_list.png)[![Job Detail](docs/img_job_detail.png)](docs/img_job_detail.png)Job detail gets updated automatically while the job is running.

**All the pages are also responsive for mobile use.**

Extending the templates can be done like this:

```
{# templates/job/detail.html.twig #}

{% extends '@JobQueue/job/detail.html.twig' %}

{% block title %}...{% endblock %}

{% block header %}...{% endblock %}

{% block body %}...{% endblock %}
```

To change or add translations for a new locale, use translation variables from bundle's translations in your translations/messages.{locale}.yaml:

(Currently there are only translations for *en* and *cs* locales)

Testing
-------

[](#testing)

The bundle has ready tests for job creations in the tests/ folder. Running tests in your app can be done like this:

```
vendor/bin/phpunit vendor/tomatom/jobqueuebundle/tests/
```

The tests are also run on every push / pull request on GitHub.

Dependencies
------------

[](#dependencies)

- "php": ">=8.1",
- "doctrine/doctrine-bundle": "^2",
- "doctrine/orm": "^2|^3",
- "dragonmantank/cron-expression": "^3",
- "knplabs/knp-paginator-bundle": "^6",
- "spiriitlabs/form-filter-bundle": "^11",
- "symfony/form": "^6.4 || ^7.4",
- "symfony/framework-bundle": "^6.4 || ^7.4",
- "symfony/lock": "^6.4 || ^7.4",
- "symfony/messenger": "^6.4 || ^7.4",
- "symfony/process": "^6.4 || ^7.4",
- "symfony/scheduler": "^6.4 || ^7.4",
- "symfony/security-bundle": "^6.4 || ^7.4",
- "symfony/translation": "^6.4 || ^7.4",
- "twig/twig": "^2|^3"

TODO
----

[](#todo)

- [Handle getting changes of recurring jobs in better way](/../../issues/3)
- Handle jobs output better (key:value)

Additional info / Contributing
------------------------------

[](#additional-info--contributing)

Special thanks to [schmittjoh](https://github.com/schmittjoh) for the original [JMSJobQueueBundle](https://github.com/schmittjoh/JMSJobQueueBundle).

This bundle **is not a fork, nor is building on top of the original bundle**, it's our own take on the console command scheduling, so please bear that in mind when using it. However, going from the original to this bundle should be seamless.

Feel free to open any issues or pull requests if you find something wrong or missing what you'd like the bundle to have!

###  Health Score

48

—

FairBetter than 95% of packages

Maintenance72

Regular maintenance activity

Popularity32

Limited adoption so far

Community15

Small or concentrated contributor base

Maturity62

Established project with proven stability

 Bus Factor1

Top contributor holds 96.3% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~38 days

Total

23

Last Release

159d ago

Major Versions

v1.2.0 → v2.0.02025-02-04

### Community

Maintainers

![](https://www.gravatar.com/avatar/4b48157319455da51aeeb00249e27e6ac3b8d61a2fd389dfa95c18a75a2378d6?d=identicon)[sajfi](/maintainers/sajfi)

---

Top Contributors

[![Matys333](https://avatars.githubusercontent.com/u/84638491?v=4)](https://github.com/Matys333 "Matys333 (105 commits)")[![deepakdhanji](https://avatars.githubusercontent.com/u/4023385?v=4)](https://github.com/deepakdhanji "deepakdhanji (2 commits)")[![paroe](https://avatars.githubusercontent.com/u/1745121?v=4)](https://github.com/paroe "paroe (1 commits)")[![sajfi](https://avatars.githubusercontent.com/u/597035?v=4)](https://github.com/sajfi "sajfi (1 commits)")

---

Tags

command-schedulerjob-queuejob-schedulerschedulersymfony-bundleasyncschedulersymfonybundleworkertask-queuequeue-managementjob queuebackground processingJob Schedulingtask schedulingjob processing

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/tomatom-jobqueuebundle/health.svg)

```
[![Health](https://phpackages.com/badges/tomatom-jobqueuebundle/health.svg)](https://phpackages.com/packages/tomatom-jobqueuebundle)
```

###  Alternatives

[sylius/sylius

E-Commerce platform for PHP, based on Symfony framework.

8.4k5.6M651](/packages/sylius-sylius)[sulu/sulu

Core framework that implements the functionality of the Sulu content management system

1.3k1.3M152](/packages/sulu-sulu)[prestashop/prestashop

PrestaShop is an Open Source e-commerce platform, committed to providing the best shopping cart experience for both merchants and customers.

9.0k15.4k](/packages/prestashop-prestashop)[contao/core-bundle

Contao Open Source CMS

1231.6M2.4k](/packages/contao-core-bundle)[ec-cube/ec-cube

EC-CUBE EC open platform.

78527.0k1](/packages/ec-cube-ec-cube)[shopware/platform

The Shopware e-commerce core

3.3k1.5M3](/packages/shopware-platform)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)