PHPackages                             slc/beanstalkmc - 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. [Utility & Helpers](/categories/utility)
4. /
5. slc/beanstalkmc

ActiveLibrary[Utility & Helpers](/categories/utility)

slc/beanstalkmc
===============

Beanstalk multi connection library

07PHP

Since Jan 15Pushed 11y ago1 watchersCompare

[ Source](https://github.com/Degola/beanstalk-multi-connection-php-library)[ Packagist](https://packagist.org/packages/slc/beanstalkmc)[ RSS](/packages/slc-beanstalkmc/feed)WikiDiscussions master Synced 1mo ago

READMEChangelogDependenciesVersions (1)Used By (0)

beanstalk-multi-connection-php-library
======================================

[](#beanstalk-multi-connection-php-library)

Beanstalk Multi Connection PHP Library

This library is for the beanstalkd message queue () and was designed to handle huge amount of messages within high-latency networks where the message ping-pong between the receipient and queue server slows down the processing dramatically.

To avoid that we built a library which makes use of hundred or even thousands of connections to the message queue server to be able retrieve all messages as fast as possible.

We use this library in a productive environment with a throughput of thousands of messages per second.

Create instance and connect to beanstalk
----------------------------------------

[](#create-instance-and-connect-to-beanstalk)

```
$beanstalk = new \slc\beanstalkmc\Beanstalk(array(
	'Host' => $beanstalk_host,
	'Port' => $beanstalk_port,
	'Connections' => 1
));

```

Publish message / job
---------------------

[](#publish-message--job)

```
$beanstalk->publishMessage(
	$message,
    $tube = "DefaultTube",
    $priority = 0,
    $delay = 0,
    $timeToRun = 600
);

```

Watch tube
----------

[](#watch-tube)

```
$beanstalk->watch($tube);

```

Start reserving jobs on all open connections
--------------------------------------------

[](#start-reserving-jobs-on-all-open-connections)

```
$beanstalk->startReserve();

```

Fetching jobs as soon as they come in
-------------------------------------

[](#fetching-jobs-as-soon-as-they-come-in)

This is the most important part, all opened connection will checked permanently for new data, newly received data will be putted into an array which will be returned after all open and non-blocking connections were handled.

```
while(is_array($jobs = $beanstalk->fetchReserved())) {
	foreach($jobs AS $job) {
         // $job is a Beanstalk_Job instance, $job->getData() gets the message content

         // delete job
         $job->delete();
         // or release job with $job->release();
	}
}

```

###  Health Score

19

—

LowBetter than 10% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity4

Limited adoption so far

Community4

Small or concentrated contributor base

Maturity41

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.

### Community

Maintainers

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

### Embed Badge

![Health badge](/badges/slc-beanstalkmc/health.svg)

```
[![Health](https://phpackages.com/badges/slc-beanstalkmc/health.svg)](https://phpackages.com/packages/slc-beanstalkmc)
```

###  Alternatives

[unisharp/laravel-ckeditor

JavaScript WYSIWYG web text editor (for laravel).

377762.3k5](/packages/unisharp-laravel-ckeditor)[aldas/modbus-tcp-client

Modbus TCP protocol client library

212130.3k](/packages/aldas-modbus-tcp-client)[laravel-admin-ext/config

Config extension for laravel-admin

97180.2k5](/packages/laravel-admin-ext-config)

PHPackages © 2026

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