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.