PHPackages                             webit/message-bus-sf-process - 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. webit/message-bus-sf-process

ActiveLibrary[Queues & Workers](/categories/queues)

webit/message-bus-sf-process
============================

1.0.0(8y ago)0331MITPHPPHP >=7.0

Since Jan 3Pushed 8y ago1 watchersCompare

[ Source](https://github.com/dbojdo/message-bus-sf-process)[ Packagist](https://packagist.org/packages/webit/message-bus-sf-process)[ RSS](/packages/webit-message-bus-sf-process/feed)WikiDiscussions master Synced today

READMEChangelog (1)Dependencies (5)Versions (3)Used By (1)

Message Bus - Symfony Process Infrastructure
============================================

[](#message-bus---symfony-process-infrastructure)

Symfony Process infrastructure for Message Bus

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

[](#installation)

```
composer require webit/message-bus-sf-process=^1.0.0
```

Usage
-----

[](#usage)

### ProcessFactory

[](#processfactory)

To use both ***ProcessPublisher*** or ***ProcessConsumer*** instance of ***ProcessFactory*** is needed.

```
use Webit\MessageBus\Message;
use Symfony\Component\Process\Process;

class MyProcessFactory implements ProcessFactory
{
    /**
     * @inheritdoc
     */
    public function create(Message $message)
    {
        return new Process(
            sprintf(
                '/usr/local/my-binary.php %s %s',
                escapeshellarg($message->type()),
                escapeshellarg($message->content())
            )
        );
    }
}
```

#### Synchronous ProcessLauncher

[](#synchronous-processlauncher)

To run process synchronously use ***SynchronousProcessLauncher***

```
use Webit\MessageBus\Infrastructure\Symfony\Process\Launcher\SynchronousProcessLauncher;

$myFactory = new MyProcessFactory();
$launcher = new SynchronousProcessLauncher($myFactory);
```

#### Asynchronous ProcessLauncher

[](#asynchronous-processlauncher)

To run process asynchronously use ***AsynchronousProcessLauncher***

```
use Webit\MessageBus\Infrastructure\Symfony\Process\Launcher\ParallelProcessManager;
use Webit\MessageBus\Infrastructure\Symfony\Process\Launcher\AsynchronousProcessLauncher;

$myFactory = new MyProcessFactory();
$launcher = new AsynchronousProcessLauncher(
    $myFactory,
    new ParallelProcessManager($maxParallelProcessNumber = 5) // to run at most 5 parallel processes
);
```

### Publisher integration

[](#publisher-integration)

Configured ***ProcessLauncher*** can be used with ***ProcessPublisher***

```
use Webit\MessageBus\Infrastructure\Symfony\Process\ProcessPublisher;
use Webit\MessageBus\Message;

$publisher = new ProcessPublisher($launcher);
$publisher->publish(new Message('type', 'content'));
```

### Consumer integration

[](#consumer-integration)

Configured ***ProcessLauncher*** can be used with ***ProcessConsumer***

```
use Webit\MessageBus\Infrastructure\Symfony\Process\ProcessConsumer;
use Webit\MessageBus\Message;

$consumer = new ProcessConsumer($launcher);
$consumer->consume(new Message('type', 'content'));
```

Running tests
-------------

[](#running-tests)

Install dependencies with composer

```
docker-compose run --rm composer
docker-compose run --rm spec
```

###  Health Score

26

—

LowBetter than 43% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity7

Limited adoption so far

Community6

Small or concentrated contributor base

Maturity59

Maturing project, gaining track record

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

Unknown

Total

1

Last Release

3048d ago

### Community

Maintainers

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

---

Tags

symfonyprocessmessage queuecommandmessage bus

### Embed Badge

![Health badge](/badges/webit-message-bus-sf-process/health.svg)

```
[![Health](https://phpackages.com/badges/webit-message-bus-sf-process/health.svg)](https://phpackages.com/packages/webit-message-bus-sf-process)
```

###  Alternatives

[jolicode/castor

A lightweight and modern task runner. Automate everything. In PHP.

53541.0k3](/packages/jolicode-castor)[qruto/laravel-flora

Install and update Laravel application with single command

13197.8k](/packages/qruto-laravel-flora)[krlove/async-service-call-bundle

Symfony bundle for asynchronous service methods calls

1153.6k](/packages/krlove-async-service-call-bundle)[ufo-tech/json-rpc-bundle

The bundle for easy using json-rpc api on your project

224.6k3](/packages/ufo-tech-json-rpc-bundle)

PHPackages © 2026

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