PHPackages                             retailcrm/symfony-beanstalkd-messenger - 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. retailcrm/symfony-beanstalkd-messenger

ActiveSymfony-bridge[Queues & Workers](/categories/queues)

retailcrm/symfony-beanstalkd-messenger
======================================

Symfony Beanstalkd Messenger Bridge

v2.0.0(2y ago)14.6k4MITPHPPHP >=7.3

Since Feb 2Pushed 2y ago5 watchersCompare

[ Source](https://github.com/retailcrm/symfony-beanstalkd-messenger)[ Packagist](https://packagist.org/packages/retailcrm/symfony-beanstalkd-messenger)[ RSS](/packages/retailcrm-symfony-beanstalkd-messenger/feed)WikiDiscussions master Synced 3w ago

READMEChangelog (4)Dependencies (6)Versions (5)Used By (0)

[![Build Status](https://github.com/retailcrm/symfony-beanstalkd-messenger/workflows/ci/badge.svg)](https://github.com/retailcrm/symfony-beanstalkd-messenger/actions)[![Coverage](https://camo.githubusercontent.com/cbf8536417c073ea179f5cae106137070f3741c49b0b32df8546507be7bfb21c/68747470733a2f2f696d672e736869656c64732e696f2f636f6465636f762f632f67682f72657461696c63726d2f73796d666f6e792d6265616e7374616c6b642d6d657373656e6765722f6d61737465722e7376673f6c6f676f3d636f6465636f76)](https://codecov.io/gh/retailcrm/symfony-beanstalkd-messenger)[![Latest stable](https://camo.githubusercontent.com/490d62fae225ed9286607d7e6b2d26dd6bc95fbc4aa1e479d8ac93d72fcc1a88/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f762f72657461696c63726d2f73796d666f6e792d6265616e7374616c6b642d6d657373656e6765722e737667)](https://packagist.org/packages/retailcrm/symfony-beanstalkd-messenger)[![PHP from Packagist](https://camo.githubusercontent.com/3f006007a88fcd189de6e7d7ea9e3fe1de9fcb927efba064e45ba5e66d37bae3/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f7068702d762f72657461696c63726d2f73796d666f6e792d6265616e7374616c6b642d6d657373656e6765722e737667)](https://packagist.org/packages/retailcrm/symfony-beanstalkd-messenger)

Symfony beanstalkd messenger
============================

[](#symfony-beanstalkd-messenger)

Beanstalkd transport for [symfony messenger](https://symfony.com/doc/current/messenger.html)

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

[](#installation)

`composer require retailcrm/symfony-beanstalkd-messenger`

Usage
-----

[](#usage)

- in the `.env` config file add the connection credentials:

`MESSENGER_TRANSPORT_DSN=beanstalkd://localhost:11300`

- create your messages and message handlers ([about messages](https://symfony.com/doc/current/messenger.html#creating-a-message-handler))
- configure messenger in `config/packages/messenger.yml`, for example:

```
framework:
    messenger:
        transports:
            async:
                dsn: "%env(MESSENGER_TRANSPORT_DSN)%"
                options:
                    queue_name: async
        routing:
            'App\Message\MyMessage': async
```

- add transport factory in `config/services.yml`

```
services:
# ...
    RetailCrm\Messenger\Beanstalkd\Transport\BeanstalkTransportFactory:
        tags: [messenger.transport_factory]
```

Allowed transport options
-------------------------

[](#allowed-transport-options)

- `tube_name` - tube name in beanstalkd
- `timeout` - timeout for receiving jobs from tube. Default - 0
- `ttr` - ttr value for jobs. Default - 60
- `not_send_if_exists` - do not send a job to the queue only if such a job is already exist. Default - `false`

All options are optional, if `tube_name` not specified will be used default queue `default`.

The `not_send_if_exists` option will only work if lock storage is specified. To do this, you need to customize the `BeanstalkTransportFactory` by adding a call to the `setLockStorage` method

```
class MyBeanstalkTransportFactory extends BeanstalkTransportFactory
//...
public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
{
    return new BeanstalkTransport(
        Connection::fromDsn($dsn, $options)->setLockStorage($this->lockStorage),
        $serializer
    );
}
//...
```

and add your custom transport factory in `config/services.yml`

```
services:
# ...
    App\Messenger\Custom\MyBeanstalkTransportFactory:
        tags: [messenger.transport_factory]
```

Your lock storage class must implement `RetailCrm\Messenger\Beanstalkd\Storage\LockStorageInterface`.

###  Health Score

30

—

LowBetter than 62% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity25

Limited adoption so far

Community15

Small or concentrated contributor base

Maturity51

Maturing project, gaining track record

 Bus Factor2

2 contributors hold 50%+ of commits

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~324 days

Total

4

Last Release

998d ago

Major Versions

v1.0.2 → v2.0.02023-10-03

PHP version history (2 changes)v1.0.0PHP >=7.2

v2.0.0PHP >=7.3

### Community

Maintainers

![](https://www.gravatar.com/avatar/d384046cee70e3b28ba79669db1a244f4ff8e87aacb2094180170cba52333e95?d=identicon)[muxx](/maintainers/muxx)

---

Top Contributors

[![gwinn](https://avatars.githubusercontent.com/u/477726?v=4)](https://github.com/gwinn "gwinn (3 commits)")[![iyzoer](https://avatars.githubusercontent.com/u/25742344?v=4)](https://github.com/iyzoer "iyzoer (3 commits)")[![azgalot](https://avatars.githubusercontent.com/u/13585657?v=4)](https://github.com/azgalot "azgalot (2 commits)")

###  Code Quality

TestsPHPUnit

Code StylePHP\_CodeSniffer

### Embed Badge

![Health badge](/badges/retailcrm-symfony-beanstalkd-messenger/health.svg)

```
[![Health](https://phpackages.com/badges/retailcrm-symfony-beanstalkd-messenger/health.svg)](https://phpackages.com/packages/retailcrm-symfony-beanstalkd-messenger)
```

###  Alternatives

[symfony/amqp-messenger

Symfony AMQP extension Messenger Bridge

29457.9M99](/packages/symfony-amqp-messenger)[symfony/doctrine-messenger

Symfony Doctrine Messenger Bridge

52992.6M231](/packages/symfony-doctrine-messenger)[symfony/redis-messenger

Symfony Redis extension Messenger Bridge

21748.1M53](/packages/symfony-redis-messenger)[symfony/amazon-sqs-messenger

Symfony Amazon SQS extension Messenger Bridge

4613.5M20](/packages/symfony-amazon-sqs-messenger)[symfony/beanstalkd-messenger

Symfony Beanstalkd Messenger Bridge

19385.0k3](/packages/symfony-beanstalkd-messenger)[jwage/phpamqplib-messenger

Symfony messenger transport for the php-amqplib/php-amqplib library.

87201.9k1](/packages/jwage-phpamqplib-messenger)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)