Perique Queue

A queue abstraction for the PinkCrab Perique Plugin Framework. Comes with a built in Action Scheduler implementation, but can be extended to be run with anything.

Why?

I needed a queue abstraction for the PinkCrab Perique Plugin Framework, and I wanted to be able to use it with the Action Scheduler, but also with a custom queue implementation. So I created this.

Installation

Composer

composer require pinkcrab/perique-queue

Usage

Setup Module

As with all Perique Modules, adding Queue to the Application is as simple as adding it to the App_Factory:

$factory = (new App_Factory(__DIR__))
    ->module( \PinkCrab\Queue\Module\Perique_Queue::class )
    ->default_setup()
    ->boot();

Action Scheduler

Out of the box Perique Queue uses the Action Scheduler to run the queue. This is the recommended way to use the queue, as it is the most reliable and performant. Nothing further is required during setup to use the Action Scheduler.

If the site has WooCommerce or any other plugin which includes the Action Scheduler, this will be used instead of the Perique Queue version and no changes are required.

For more details on setting up the module or creating custom drivers, please see the Module Docs for more details.

Events

To add an operation to the queue, a class which implements PinkCrab\Queue\Event\Event must be created. To make this process a little easier, we have 3 abstract classes which can be extended to create the event.

• PinkCrab\Queue\Event\Async_Event - A simple event which will be run as soon as the queue is processed.
• PinkCrab\Queue\Event\Delayed_Event - A simple event which will be run after a delay.
• PinkCrab\Queue\Event\Recurring_Event - A simple event which will be run after a delay, and then again after a delay.

Please see the Events Docs for more details.

Dispatching Events and Interacting with the Queue

The Queue_Service is the main class for interacting with the queue. It can be injected into any class which is created via the DI_Container.

use PinkCrab\Queue\Dispatch\Queue_Service;

class My_Class {

    public function __construct( Queue_Service $queue ) {
        $this->queue = $queue;
    }

    public function dispatch_event() {
        $this->queue->dispatch( new My_Event() );
    }

    public function get_next_event() {
        $event = $this->queue->find_next( new My_Event() );
    }

    public function cancel_next_event() {
        $this->queue->cancel_next( new My_Event() );
    }

    public function is_event_pending() {
        $pending = $this->queue->is_scheduled( new My_Event() );
    }
}

By injecting the Queue_Service as a dependency, this will allow mocking the service much easier in tests.

You can read more about the Queue_Service here.

Event Listeners

As the Queue just trigger WordPress Actions, you can just use the standard WordPress Action hooks to listen for the events.

add_action( 'my_event', function( $event ) {
    // Do something with the event.
}, 10, 1 );

But we have a custom listener which you can use if you want to create controller like classes. As with the general concept behind Perique, these are designed to be added to be added to the registration class list, and then constructed and processed via the Registration Process and the DI_Container.

To make use of this, you can easily extend from the Abstract_Listener class, and then add the class to the registration class list.

<?php
use PinkCrab\Queue\Listener\Abstract_Listener;

class My_Listener extends Abstract_Listener {

    protected string $hook = 'my_event';

    public function handle( array $args ): void {
        // Do something with the event.
    }
}

For more details on the Abstract_Listener class, please see the docs here.

Requires

• PinkCrab Perique Framework V2 and above.
• PHP7.4+

License

MIT License

http://www.opensource.org/licenses/mit-license.html

Previous Perique Support

• For support of all versions before Perique V2, please use version 1.0.* of this module.

Change Log

• 2.0.0 - Updated to support Perique V2, added docs and updated underlying verison of Action Scheduler.
• 1.0.0 - Tagged release, updates to pipelines and Dependencies for WP6.1
• 0.1.2 - Tweaks to DI Rule definitions
• 0.1.1 - Tweaks to dependencies
• 0.1.0 - Initial Release