PHPackages devgeniem/wp-queue - 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. devgeniem/wp-queue ActiveWordpress-muplugin[Queues & Workers](/categories/queues) devgeniem/wp-queue ================== WordPress Queue is a modular library for managing queued tasks in WordPress. 1.0.1(3y ago)151272[4 issues](https://github.com/devgeniem/wp-queue/issues)MITPHPPHP ^7.4 || ^8.0 || ^8.1CI passing Since Jul 1Pushed 3y ago16 watchersCompare [ Source](https://github.com/devgeniem/wp-queue)[ Packagist](https://packagist.org/packages/devgeniem/wp-queue)[ RSS](/packages/devgeniem-wp-queue/feed)WikiDiscussions master Synced 1w ago READMEChangelog (2)Dependencies (9)Versions (5)Used By (0) [![geniem-github-banner](https://cloud.githubusercontent.com/assets/5691777/14319886/9ae46166-fc1b-11e5-9630-d60aa3dc4f9e.png)](https://cloud.githubusercontent.com/assets/5691777/14319886/9ae46166-fc1b-11e5-9630-d60aa3dc4f9e.png) WordPress Queue =============== [](#wordpress-queue) [![Build Status](https://camo.githubusercontent.com/43eaba7ca87fbe3497f41b045a49b888c1914f699061851ac0151c46af66491e/68747470733a2f2f7472617669732d63692e6f72672f64657667656e69656d2f77702d71756575652e7376673f6272616e63683d6d6173746572)](https://travis-ci.org/devgeniem/wp-queue) [![Latest Stable Version](https://camo.githubusercontent.com/2bd16363ebfbf24263a301d8a573dd8623b9af484690ff3ea7e7bfbde560eae6/68747470733a2f2f706f7365722e707567782e6f72672f64657667656e69656d2f77702d71756575652f762f737461626c65)](https://packagist.org/packages/devgeniem/wp-queue) [![Total Downloads](https://camo.githubusercontent.com/463ba1357b9a1f9c3592104f16cf0d10b9edb14d37a77a902c71a73a442108f6/68747470733a2f2f706f7365722e707567782e6f72672f64657667656e69656d2f77702d71756575652f646f776e6c6f616473)](https://packagist.org/packages/devgeniem/wp-queue) [![Latest Unstable Version](https://camo.githubusercontent.com/4e5594998e9c05447f7158bb54a43a6f603a156542a0e94c28947ba879baedc1/68747470733a2f2f706f7365722e707567782e6f72672f64657667656e69656d2f77702d71756575652f762f756e737461626c65)](https://packagist.org/packages/devgeniem/wp-queue) [![License](https://camo.githubusercontent.com/fdf0bd0451276a82f694b90a300eca3237dd0939773d393cbf3a07f6d29d327a/68747470733a2f2f706f7365722e707567782e6f72672f64657667656e69656d2f77702d71756575652f6c6963656e7365)](https://packagist.org/packages/devgeniem/wp-queue) WordPress Queue is a modular library for managing queued tasks in WordPress. Installation ------------ [](#installation) Install with Composer: ``` composer config repositories.wp-queue git git@github.com:devgeniem/wp-queue.git composer require devgeniem/wp-queue ``` The plugin initializes itself in the `plugins_loaded` hook. Your code should start using the plugin features after this hook is run by WordPress. An alternative is to customize the plugin initialization hook with the provided filter `wqp_init_hook`. See [plugin.php](./plugin.php) for details. Functionalities --------------- [](#functionalities) ### Queue structure [](#queue-structure) A queue consists of its name, an entry handler and some entries. Entries are statically typed objects holding the data. An entry handler is the controller called when dequeueing a single entry. The name is used to identify the queue, for instance, with WP-CLI. Queue functionalities are defined with the `\Geniem\Queue\Interfaces\QueueInterface` interface. You can create your own queue controller by implementing this interface. We provide an abstract class, `Geniem\Queue\Instance\Base`, that you can extend as a starting point. ### Queue creation [](#queue-creation) To create a queue, call the implementation constructor with your unique name for the queue. To let WordPress Queue to know about your queue, pass it to the queue container via the `wpq_add_queue` hook. The queue container implements the [PSR-11](https://www.php-fig.org/psr/psr-11/) container interface. Here is an example of creating a Redis queue: ``` add_action( 'wpq_add_queue', function( \Psr\Container\ContainerInterface $container ) { $my_queue = new Geniem\Queue\Instance\RedisQueue( 'my_queue' ); // ... $container->add( $my_queue ); }, 1, 1 ); ``` When creating a new queue, all its entries should be stored in the protected `$entries` property as an instance of a class implementing the `\Geniem\Queue\Interfaces\EntryInterface`. The actual entry data is untyped, but we encourage keeping the type consistent withing a specific queue. The actual entry handler can be created by implementing the `\Geniem\Queue\Interfaces\EntryFetcherInterface` interface. The queue creation is handled with the `Geniem\Queue\QueueCreator` class. This ensures all dependecies are strictly typed and injected in place. ### Accessing a queue [](#accessing-a-queue) To interact manually with your previously created queue, you can access it through the plugin's queue container. To access the plugin, you can use the global helper function `wpq()`. It returns the plugin singleton. ``` $my_queue = wpq()->get_queue_container()->get( 'my_queue' ); ``` ### Entry handling [](#entry-handling) A queue consists of a list of entries implementing the `\Geniem\Queue\Interfaces\EntryInterface` interface. WordPress Queue is agnostic about the handling of entries. It is left for you to implement. The dequeuer uses a try-catch block around calling the handle method. Thus, your handler should throw errors if the handling process fails. This enables logging errors and deciding whether to proceed with the dequeue or to rollback to the previous state in the queue. Here is an example of a simple handler that just logs the data in the queue. ``` class MyHandler implements \Geniem\Queue\Interfaces\EntryHandlerInterface { public function handle( \Geniem\Queue\Interfaces\EntryInterface $entry ) { error_log( 'Entry data: ' . $entry->get_data() ); } } ``` After creating the handler, pass an instance to your queue: ``` add_action( 'wpq_add_queue', function( \Psr\Container\ContainerInterface $container ) { $my_queue = new Geniem\Queue\Instance\RedisQueue( 'my_queue' ); // Set the handler. $my_queue->set_entry_handler( new Myhandler() ); $container->add( $my_queue ); }, 1, 1 ); ``` ### Entry fetching and enqueueing [](#entry-fetching-and-enqueueing) WordPress Queue introduces a concept of a 'fetcher'. A fetcher is an instance with a functionality of fetching more entries for a queue. Fetchers should implement the `\Geniem\Queue\Interfaces\EntryFetcherInterface` interface. One example of using a fetcher is to integrate your queue to an external API providing some data to be passed to the queue. The `Geniem\Queue\Enqueuer` class calls the fetcher's fetch method and wraps the resulting array items into entry objects if not already wrapped. After this, each entry is run through the `enqueue` method of the given queue instance. Here is a simple fetcher example always returning the same array of entries. ``` class MyFetcher implements \Geniem\Queue\Interfaces\EntryFetcherInterface { public function fetch() : ?array { $entry_data = [ 'Item 1', 'Item 2', 'Item 3', 'Item 4', ]; return $entries; } } ``` And then, adding an fetcher instance for your queue: ``` add_action( 'wpq_add_queue', function( \Psr\Container\ContainerInterface $container ) { $my_queue = new Geniem\Queue\Instance\RedisQueue( 'my_queue' ); // Set the fetcher. $my_queue->set_entry_fetcher( new MyFetcher() ); $container->add( $my_queue ); }, 1, 1 ); ``` The fetching process is run with the `Geniem\Queue\Enqueuer`. You can run it with the WP-CLI command or if you want to do it manually in PHP, run the following: ``` $enqueuer = new \Geniem\Queue\Enqueuer(); $enqueuer->fetch( $my_queue ); ``` To enqueue a single entry, call the `enqueue` method and pass an entry: ``` $entry = ( new \Geniem\Queue\Entry() )->set_data( 'Just a string' ); $enqueuer = new \Geniem\Queue\Dequeuer(); $enqueuer->enqueue( $my_queue, $entry ); ``` *Note! You can call the enqueue method directly from your queue instance, but we recommend using the enqueuer for generalized error handling and logging.* ### Dequeueing [](#dequeueing) A dequeue process handles the first entry in a queue. If the handing is successful, the entry is popped out from the queue. Note that the final implementation of the queue processsing is dependant of the queue class. The dequeue process is handled by the `Geniem\Queue\Dequeuer`. When using the WP-CLI commands, this is done automatically. If you want to manually run the dequeu, do the following: ``` $dequeuer = new \Geniem\Queue\Dequeuer(); $dequeuer->dequeue( $my_queue ); ``` *Note! You can call the dequeue method directly from your queue instance, but we recommend using the dequeuer for generalized error handling and logging.* Example ------- [](#example) In the following examples we create a simple fetcher returning an array of entries containing a simple string in the data. Then finally the handler just logs the data into PHP error log. The whole process is completed with creating a Redis queue. After this, the queue is accessible through WP-CLI. #### Fetcher example [](#fetcher-example) ``` class MyFetcher implements \Geniem\Queue\Interfaces\EntryFetcherInterface { public function fetch() : ?array { $entry_data = [ 'Item 1', 'Item 2', 'Item 3', 'Item 4', ]; $entries = array_map( function( $data ) { $entry = new \Geniem\Queue\Entry(); $entry->set_data( $data ); return $entry; }, $entry_data ); return $entries; } } ``` #### Handler example [](#handler-example) ``` class MyHandler implements \Geniem\Queue\Interfaces\EntryHandlerInterface { public function handle( \Geniem\Queue\Interfaces\EntryInterface $entry ) { error_log( 'Entry data: ' . $entry->get_data() ); } } ``` ### Usage example [](#usage-example) To allow WordPress Queue to find our example queue by its name "my\_queue", we must define it by adding it to the queue container in the `wpq_add_queue` hook. Here we use the default RedisQueue as our queue instance. To add a new queue into the container call the `add` method. To replace an existing one with the same name, call the `replace` method. ``` add_action( 'wpq_add_queue', function( \Psr\Container\ContainerInterface $container ) { $redis_queue = new Geniem\Queue\Instance\RedisQueue( 'my_queue' ); $redis_queue->set_entry_fetcher( new MyFetcher() ); $redis_queue->set_entry_handler( new MyHandler() ); $container->add( $redis_queue ); }, 1, 1 ); ``` WP-CLI commands --------------- [](#wp-cli-commands) After the queue has been instantiated and added to the queue container, you can start to interact with it through WP-CLI. ### Create [](#create) To create the queue, call the WP-CLI `create` command. This will run the entry fetcher if one is set for the queue and (re)create the queue by saving it with the newly fetched entries. ``` wp queue create my_queue ``` ### Dequeue [](#dequeue) After creating, you can dequeue a single entry from the queue: ``` wp queue dequeue my_queue ``` ### Fetch [](#fetch) To fetch more entries to the queue, run the `fetch` command. This command will try to call the fetcher's `fetch` method and append the found entries to the queue. ``` wp queue fetch my_queue ``` Tests ----- [](#tests) The plugin is tested locally with [PHPUnit](https://phpunit.de/) and automatically with the GitHub integration of [Travic CI](https://travis-ci.org/). For local testing we provide a Dockerfile configuration to run PHPUnit inside a Docker container. The container also contains [pywatch](https://pypi.org/project/pywatch/) for watching changes tests and then rerunning them. To start running tests locally, navigate to your plugin directory and follow this process: ``` # Install local composer packages. composer install # Build and tag the container. docker build . -t phptest:7.4 # Run the container and watch changes. docker run --rm -it -v $(pwd):/opt phptest:7.4 "php ./vendor/bin/phpunit" ./tests/*.php ``` Contributors ------------ [](#contributors) - [Check the up-to-date list here](https://github.com/devgeniem/wp-queue/graphs/contributors) ### Health Score 32 — LowBetter than 72% of packages Maintenance15 Infrequent updates — may be unmaintained Popularity19 Limited adoption so far Community14 Small or concentrated contributor base Maturity67 Established project with proven stability Bus Factor1 Top contributor holds 75% 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 ~472 days Total 3 Last Release 1202d ago Major Versions 0.0.0 → 1.0.02021-08-27 PHP version history (3 changes)0.0.0PHP ^7.2 1.0.0PHP ^7.3 1.0.1PHP ^7.4 || ^8.0 || ^8.1 ### Community Maintainers ![](https://avatars.githubusercontent.com/u/11960000?v=4)[Hion Digital Oy](/maintainers/devgeniem)[@devgeniem](https://github.com/devgeniem) --- Top Contributors [![ivuorinen](https://avatars.githubusercontent.com/u/11024?v=4)](https://github.com/ivuorinen "ivuorinen (3 commits)")[![mrkimmok](https://avatars.githubusercontent.com/u/54927315?v=4)](https://github.com/mrkimmok "mrkimmok (1 commits)") --- Tags asynchronouswordpressqueuemu-pluginbackground process ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/devgeniem-wp-queue/health.svg) ``` [![Health](https://phpackages.com/badges/devgeniem-wp-queue/health.svg)](https://phpackages.com/packages/devgeniem-wp-queue) ``` ### Alternatives [enqueue/enqueue Message Queue Library 19820.0M56](/packages/enqueue-enqueue)[a5hleyrich/wp-queue WordPress job queues 18021.5k1](/packages/a5hleyrich-wp-queue)[orisai/scheduler Cron job scheduler - with locks, parallelism and more 4037.1k4](/packages/orisai-scheduler)[deliciousbrains/wp-queue WordPress job queues 1807.4k1](/packages/deliciousbrains-wp-queue)[deliciousbrains/wp-image-processing-queue Resize WordPress images in the background 2061.4k](/packages/deliciousbrains-wp-image-processing-queue)[fghazaleh/multi-thread-manager Multi-thread manager using Symfony process component 172.6k](/packages/fghazaleh-multi-thread-manager) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)