PHPackages                             cog/stupidmqbundle - 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 &amp; Workers](/categories/queues)
4. /
5. cog/stupidmqbundle

AbandonedLibrary[Queues &amp; Workers](/categories/queues)

cog/stupidmqbundle
==================

stupid message queue bundle for sf2

2.4.7(11y ago)111.8k3[2 issues](https://github.com/krichprollsch/stupidMQBundle/issues)MITPHPPHP &gt;=5.3.3

Since Nov 8Pushed 11y ago1 watchersCompare

[ Source](https://github.com/krichprollsch/stupidMQBundle)[ Packagist](https://packagist.org/packages/cog/stupidmqbundle)[ Docs](https://github.com/krichprollsch/stupidMQBundle)[ RSS](/packages/cog-stupidmqbundle/feed)WikiDiscussions master Synced 1mo ago

READMEChangelogDependencies (8)Versions (20)Used By (0)

StupidMQBundle
==============

[](#stupidmqbundle)

Bundle to support stupidMessageQueue into Symfony application.

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

[](#installation)

Add requirement into you `composer.json` :

```
"cog/stupidmqbundle":"2.4.*"

```

Then enable the bundle into `app/AppKernel.php` :

```
new CoG\StupidMQBundle\CoGStupidMQBundle()

```

Optionnaly, if you are using Doctrine Orm, you can use it to easily install message queue table :

```
php app/console doctrine:schema:update --force

```

This command will create for you a new table `cog_stupidmq` to store your messages.

Creating a message queue
------------------------

[](#creating-a-message-queue)

Edit your `services.xml` to add your own queues :

```

    my.queue

```

Adding message into the queue
-----------------------------

[](#adding-message-into-the-queue)

```
$queue = $this->getContainer()->get('my.queue');
$queue->publish('This is a message !');
```

Adding a worker
---------------

[](#adding-a-worker)

To consume messages, you have to create a worker class like this :

```
