Path
projects / org / mugo.ca / queue-bundle
Search!
Find the Exponential Software extensions you want
queue-bundle
| UNIX name | Owner | Status |
|---|---|---|
| queue-bundle | Mugo.ca | stable |
| Version | Compatible with |
|---|---|
| N/A | N/A |
Installation
You first need to decide which transporter you would like to use. There are several options: https://php-enqueue.github.io/transport
For example, you want to use the file system to store the queue, you would need to install the enqueue package for that transporter
composer require enqueue/fs
Configure the transporter by either setting the environment variable or directly change the configuration file 'config/packages/enqueue.yaml'
Set the ENQUEUE_DSN variable to
ENQUEUE_DSN=file:
It will store the queue in the system temporary directory.
Commands
# To produce messages:
./bin/console mugo:queue:produce
# To process messages:
./bin/console enqueue:transport:consume
# To clear queue:
./bin/console mugo:queue:purge
Creating a new Queue
Create queue service class
Configure queue service class
MugoWeb\QueueBundle\Queue\ExampleProcessor:
tags:
- { name: 'enqueue.transport.processor', processor: 'example_processor' }