PHPackages                             magefast/module-qprocess - 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. magefast/module-qprocess

ActiveMagento2-module[Queues & Workers](/categories/queues)

magefast/module-qprocess
========================

Magento module, Easy Add Task to Queue

1.0.3(6mo ago)201proprietaryPHP

Since Oct 27Pushed 6mo ago2 watchersCompare

[ Source](https://github.com/magefast/Magefast_Qprocess)[ Packagist](https://packagist.org/packages/magefast/module-qprocess)[ RSS](/packages/magefast-module-qprocess/feed)WikiDiscussions master Synced 1mo ago

READMEChangelog (1)Dependencies (1)Versions (2)Used By (0)

Magefast\_Qprocess.
Magento module, Easy Add Task to Queue
===========================================================

[](#magefast_qprocess-magento-module-easy-add-task-to-queue)

Sample module how can add Queue Message and processing it.
----------------------------------------------------------

[](#sample-module-how-can-add-queue-message-and-processing-it)

#### CLI command for retrieve list of all configured Queue Message:

[](#cli-command-for-retrieve-list-of-all-configured-queue-message)

`bin/magento queue:consumers:list`

#### CLI command for watch/listen Queue Messages:

[](#cli-command-for-watchlisten-queue-messages)

`bin/magento queue:consumers:start -vvv qprocess.task`

### CLI command for add test Queue Message:

[](#cli-command-for-add-test-queue-message)

`bin/magento qprocess:test`

#### Service for Publish (add) Queue Message

[](#service-for-publish-add-queue-message)

`\Magefast\Qprocess\Service\Add::execute`

#### Method where processed Queue Message, here can(need) add custom logic for processing - add Event, Service etc.

[](#method-where-processed-queue-message-here-canneed-add-custom-logic-for-processing---add-event-service-etc)

`\Magefast\Qprocess\Model\Task::processMessage`

Sample: How To add Task to Queue with this Module Magefast\_Qprocess
--------------------------------------------------------------------

[](#sample-how-to-add-task-to-queue-with-this-module-magefast_qprocess)

1. For example in Observer Class for event `catalog_product_save_after` need add Task for Sync/Send SMS
    or Call to External services.
    Bellow sample of Observer Class

```
namespace Strekoza\Sample\Observer;

use Magefast\Qprocess\Service\Add;
use Magento\Catalog\Model\Product;
use Magento\Framework\Event\Observer as EventObserver;
use Magento\Framework\Event\ObserverInterface;
use Magento\Framework\Serialize\Serializer\Json;

class ProductUpdateObserver implements ObserverInterface
{
    private Json $json;
    private Add $addMessageQueue;

    public function __construct(
        Json $json,
        Add  $addMessageQueue
    )
    {
        $this->json = $json;
        $this->addMessageQueue = $addMessageQueue;
    }

    public function execute(EventObserver $observer)
    {
        /** @var Product $product */
        $product = $observer->getEvent()->getProduct();

        /**
         * Add to QUEUE
         */
        $objectData = [];
        $objectData['sku'] = $product->getSku();

        $jsonData = [
            'type' => 'custom_task_product',
            'data' => $objectData
        ];

        $jsonSting = $this->json->serialize($jsonData);

        $this->addMessageQueue->execute('qprocess.task', $jsonSting);
    }
}

```

2) Add solution for Processing of Task, that added before. It will added with event `qprocess\_task`. Bellow peace of code for `etc/events.xml` ```

```

And Observer Class `QprocessTask`

 ```
namespace Strekoza\Sample\Observer;

use Exception;
use Magento\Framework\Event\Observer;
use Magento\Framework\Event\ObserverInterface;
use Magento\Framework\Serialize\Serializer\Json;

class QprocessTask implements ObserverInterface
{
    private Json $json;

    public function __construct(
        Json $json
    )
    {
        $this->json = $json;
    }

    public function execute(Observer $observer)
    {
        $object = $observer->getEvent()->getObject();

        $data = $this->json->unserialize($object->getValue());

        if (!is_array($data)) {
            return;
        }

        if (!isset($data['type']) || !isset($data['data'])) {
            $object->setResult(false);
            return;
        }

        if ($data['type'] == 'custom_task_product') {
            try {

                $sku = $data['data']['sku'];
                //@todo YOUR LOGIC HERE with $sku of Product

                return;
            } catch (Exception $e) {
                return;
            }
        }
    }
}
```

3) Its All. Take a look, if class/file `Observer\\QprocessTask` is changed, need also regenerate code. Install With Composer
---------------------

[](#install-with-composer)

`composer require magefast/module-qprocess`

### Links

[](#links)

###  Health Score

30

—

LowBetter than 64% of packages

Maintenance66

Regular maintenance activity

Popularity4

Limited adoption so far

Community9

Small or concentrated contributor base

Maturity35

Early-stage or recently created project

 Bus Factor1

Top contributor holds 100% 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

Unknown

Total

1

Last Release

203d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/f2bc71978dc2c30c99145efe031c759ebd93efdc61c13965b58ab362ac4e59c7?d=identicon)[magefast](/maintainers/magefast)

---

Top Contributors

[![magefast](https://avatars.githubusercontent.com/u/1673611?v=4)](https://github.com/magefast "magefast (28 commits)")

---

Tags

magento2magento2-modulequeue

### Embed Badge

![Health badge](/badges/magefast-module-qprocess/health.svg)

```
[![Health](https://phpackages.com/badges/magefast-module-qprocess/health.svg)](https://phpackages.com/packages/magefast-module-qprocess)
```

###  Alternatives

[league/geotools

Geo-related tools PHP 7.3+ library

1.4k5.3M26](/packages/league-geotools)[react/async

Async utilities and fibers for ReactPHP

2228.8M171](/packages/react-async)[run-as-root/magento2-message-queue-retry

Provides message queue retry processing functionality via RabbitMQ's dead letter exchange.

64102.8k](/packages/run-as-root-magento2-message-queue-retry)[belvg/module-sqs

N/A

1544.4k](/packages/belvg-module-sqs)

PHPackages © 2026

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