PHPackages                             overblog/activemq-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. overblog/activemq-bundle

ActiveSymfony-bundle

overblog/activemq-bundle
========================

OverBlog ActiveMQ Bundle

2.1.0(8y ago)1042.5k↓50%6[3 issues](https://github.com/overblog/ActiveMqBundle/issues)PHPPHP >=5.3.3

Since Nov 13Pushed 3y ago18 watchersCompare

[ Source](https://github.com/overblog/ActiveMqBundle)[ Packagist](https://packagist.org/packages/overblog/activemq-bundle)[ Docs](https://github.com/overblog/ActiveMqBundle.git)[ RSS](/packages/overblog-activemq-bundle/feed)WikiDiscussions master Synced 1mo ago

READMEChangelog (3)Dependencies (2)Versions (12)Used By (0)

OverblogActiveMqBundle
======================

[](#overblogactivemqbundle)

ActiveMQ Bundle for the Symfony.

Installation
------------

[](#installation)

```
composer req overblog/activemq-bundle

```

Usage
-----

[](#usage)

Define publishers and consumers:

```
overblog_active_mq:
    connections:
        default:
            user: '%env(MQ_USER)%'
            password: '%env(MQ_PASSWORD)%'
            servers: '%mq_servers%'

    publishers:
        foo:
            connection: default
            options:
                type: queue
                name: foo.notification
        bar:
            connection: default
            options:
                type: queue
                name: bar.notification
    consumers:
        foo:
            connection: default
            handler: App\Consumer\FooConsumer
            options:
                type: queue
                name: foo.notification # queue name
                prefetchSize: 10
        bar:
            connection: default
            handler: App\Consumer\BarConsumer
            options:
                type: queue
                name: bar.notification
                prefetchSize: 10

services:
    App\Consumer\BarConsumer: ~
    App\Consumer\FooConsumer: ~
```

An example of how to publish a message: you can access publisher using service id `overblog_active_mq.{PUBLISHER_NAME}` for example `overblog_active_mq.foo` or `overblog_active_mq.bar` for above configuration. Services is not public so create a public alias or inject it.

```