silpo-tech / message-bus-bundle
Message bus bundle for Symfony
Installs: 61
Dependents: 1
Suggesters: 1
Security: 0
Stars: 1
Watchers: 0
Forks: 2
Open Issues: 0
Type:symfony-bundle
pkg:composer/silpo-tech/message-bus-bundle
Requires
- php: >=8.1
- ext-amqp: *
- enqueue/amqp-lib: ^0.10.9
- enqueue/enqueue-bundle: ^0.10
- php-amqplib/php-amqplib: ^3.5.1
- silpo-tech/mapper-bundle: ^1.0
- symfony/console: ^7.0
- symfony/doctrine-bridge: ^7.3
- symfony/event-dispatcher: ^7.0
- symfony/expression-language: ^7.0
- symfony/serializer: ^7.0
- symfony/uid: ^7.0
Requires (Dev)
- friendsofphp/php-cs-fixer: ^3.0
- monolog/monolog: ^2.0|^3.0
- php-solution/sf-functional-test: ^6.0
- phpstan/phpstan: ^2.0
- phpunit/phpunit: ^11.4
- sentry/sentry: ^3.0|^4.0
- silpo-tech/lib-test-utilities: ^1.0
- symfony/framework-bundle: ^7.0
- symfony/validator: ^7.0
- symfony/yaml: ^7.0
Suggests
- ext-zlib: to use message compression
README
Development
Run tests
make test # SKIP_INSTALL=true (if you have already installed dependencies)
To list all available commands
make help
Installation
Require the bundle and its dependencies with composer:
$ composer require silpo-tech/message-bus-bundle
Register the bundle:
// project/config/bundles.php return [ MessageBusBundle\MessageBusBundle::class => ['all' => true], ];
Add tags to batch processor to tell application where to look for batch processors
MessageBusBundle\EnqueueProcessor\Batch\BatchProcessorInterface: tags: - 'enqueue.transport.processor' - name: !php/const MessageBusBundle\EnqueueProcessor\Batch\AbstractBatchProcessor::BATCH_PROCESSOR_TAG indexed_by: key
Start consuming:
./bin/console enqueue:consume --setup-broker -vvv
How to enable messages compression:
message_bus: default_encoder: gzip #available: null, gzip, zlib, deflate
and use MessageBusBundle\Producer\EncoderProducerInterface in your project*. Such service is not available by default.
- Do not forget to enable zlib extension at PHP.