PHPackages                             oro/message-queue-bundle - 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. oro/message-queue-bundle

Abandoned → [oro/platform](/?search=oro%2Fplatform)ArchivedSymfony-bundle[Queues & Workers](/categories/queues)

oro/message-queue-bundle
========================

ORO Message Queue Bundle

902PHP

Since May 18Pushed 8y ago15 watchersCompare

[ Source](https://github.com/oroinc/OroMessageQueueBundle)[ Packagist](https://packagist.org/packages/oro/message-queue-bundle)[ RSS](/packages/oro-message-queue-bundle/feed)WikiDiscussions master Synced 4w ago

READMEChangelogDependenciesVersions (1)Used By (0)

OroMessageQueue Bundle
======================

[](#oromessagequeue-bundle)

*Note:* This article is published in the Oro documentation library.

OroMessageQueueBundle incorporates the OroMessageQueue component into OroPlatform and thereby provides message queue processing capabilities for all application components.

Table of Contents
-----------------

[](#table-of-contents)

- [Overview](#overview)
- [Usage](#usage)
- [consumer options](#consumer-options)
- [Supervisord](#supervisord)
- [Name prefix the for Message Queue](#name-prefix-for-the-message-queue)
- [Internals](#internals)
    - [Structure](#structure)
    - [Flow](#flow)
    - [Custom transport](#custom-transport)
    - [Key Classes](#key-classes)
- [Unit and Functional tests](#unit-and-functional-tests)
- [Stale Jobs](#stale-jobs)
- [Consumer heartbeat](#consumer-heartbeat)
- [Resetting Symfony Container in consumer](Resources/doc/container_in_consumer.md)
- [Security Context in consumer](Resources/doc/secutity_context.md)
- [Buffering Messages](Resources/doc/buffering_messages.md)

Overview
--------

[](#overview)

The bundle integrates OroMessageQueue component. It adds easy to use configuration layer, register services and tie them together, register handy cli commands.

Jobs
----

[](#jobs)

The bundle provides an entity and a web gui for [the jobs](../../Component/MessageQueue/README.md#jobs). So the jobs are created in the db and have a web gui where you can monitor jobs status and interrupt jobs.

Usage
-----

[](#usage)

First, you have to configure a transport layer and set one to be default. For the config settings

```
# config/config.yml

oro_message_queue:
    transport:
        default: '%message_queue_transport%'
        '%message_queue_transport%': '%message_queue_transport_config%'
    client: ~
```

we can configure one of the supported transports via parameters:

### DBAL transport

[](#dbal-transport)

```
# config/parameters.yml

    message_queue_transport: DBAL
    message_queue_transport_config: ~
```

[DBAL transport options](./Resources/doc/dbal.md)

Once you configured everything you can start producing messages:

```