PHPackages                             inteve/message-queue - 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. inteve/message-queue

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

inteve/message-queue
====================

Simple message queue

v2.1.0(6mo ago)06BSD-3-ClausePHPPHP 8.0 - 8.2CI passing

Since Nov 2Pushed 6mo ago1 watchersCompare

[ Source](https://github.com/inteve/message-queue)[ Packagist](https://packagist.org/packages/inteve/message-queue)[ Fund](https://www.janpecha.cz/donate/)[ RSS](/packages/inteve-message-queue/feed)WikiDiscussions master Synced 1mo ago

READMEChangelogDependencies (3)Versions (4)Used By (0)

Inteve\\MessageQueue
====================

[](#intevemessagequeue)

[![Build Status](https://github.com/inteve/message-queue/workflows/Build/badge.svg)](https://github.com/inteve/message-queue/actions)[![Downloads this Month](https://camo.githubusercontent.com/993a39cb5a17966646e348cb324a50115f9a7ebbb0cc2e0691b0a9cc3c503553/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f646d2f696e746576652f6d6573736167652d71756575652e737667)](https://packagist.org/packages/inteve/message-queue)[![Latest Stable Version](https://camo.githubusercontent.com/7838e39b13ea59fefeb3079165aa31d6041dd8ea9e19503bc8361f45fe2d9d0e/68747470733a2f2f706f7365722e707567782e6f72672f696e746576652f6d6573736167652d71756575652f762f737461626c65)](https://github.com/inteve/message-queue/releases)[![License](https://camo.githubusercontent.com/fa7d5fcf2c84b580327af52da95dd751703af65f079dc3c5a0081beac0789718/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f6c6963656e73652d4e65772532304253442d626c75652e737667)](https://github.com/inteve/message-queue/blob/master/license.md)

Simple message queue

[![Donate](https://camo.githubusercontent.com/101b981194f1dafbf9c42e19c3034fe2d724e75be972cef0f4477074997834db/68747470733a2f2f6275796d65636f666665652e696e746d2e6f72672f696d672f646f6e6174652d62616e6e65722e76312e737667)](https://www.janpecha.cz/donate/)

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

[](#installation)

[Download a latest package](https://github.com/inteve/message-queue/releases) or use [Composer](http://getcomposer.org/):

```
composer require inteve/message-queue

```

Inteve\\MessageQueue requires PHP 8.0 or later.

Usage
-----

[](#usage)

```
$exceptionHandler = function (\Throwable $e) {
	\Tracy\Debugger::log($e, \Tracy\Debugger::EXCEPTION);
};
$dateTimeFactory = new MyDateTimeFactory; // implementation of Phig\DateTimeFactory
$adapter = new MemoryAdapter($exceptionHandler);
$manager = new Manager($adapter, $dateTimeFactory);
```

### Insert message

[](#insert-message)

```
$manager->create(
	queue: 'name-of-queue',
	data: [
		'field' => 'value',
		'field2' => 'value2',
	]
);
```

### Consume message

[](#consume-message)

Process message from given queue:

```
$manager->fetch(
	queue: 'name-of-queue',
	handler: function (array $data) {
		$data['field'];
		$data['field2'];
	}
);
```

Process messages from ALL queues (logs missing handlers via `$exceptionHandler`):

```
$message = $manager->multiFetch(
	handlers: [
		'name-of-queue' => function (array $data) {
			$data['field'];
			$data['field2'];
		}
		'name-of-queue-B' => function (array $data) {
			$data['field'];
			$data['field2'];
		}
	],
	limit: 10 // number of messages processed in multiFetch() call
);
```

Process messages from SPECIFIC queues:

```
$message = $manager->multiFetch(
	handlers: [
		'name-of-queue' => function (array $data) {
			$data['field'];
			$data['field2'];
		}
		'name-of-queue-B' => function (array $data) {
			$data['field'];
			$data['field2'];
		}
	],
	limit: 10, // number of messages processed in multiFetch() call
	fetchFrom: $mananger::FROM_LISTED_ONLY
);
```

---

License: [New BSD License](license.md)
Author: Jan Pecha,

###  Health Score

36

—

LowBetter than 82% of packages

Maintenance66

Regular maintenance activity

Popularity4

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity57

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

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 ~364 days

Total

3

Last Release

200d ago

Major Versions

v1.0.0 → v2.0.02023-11-02

PHP version history (2 changes)v1.0.0PHP 7.4 - 8.2

v2.1.0PHP 8.0 - 8.2

### Community

Maintainers

![](https://www.gravatar.com/avatar/5c980b1511b4a0350442dc23d89c99d4d9a2411b7e765d52c133ccacf616968b?d=identicon)[janpecha](/maintainers/janpecha)

---

Top Contributors

[![janpecha](https://avatars.githubusercontent.com/u/637719?v=4)](https://github.com/janpecha "janpecha (15 commits)")

### Embed Badge

![Health badge](/badges/inteve-message-queue/health.svg)

```
[![Health](https://phpackages.com/badges/inteve-message-queue/health.svg)](https://phpackages.com/packages/inteve-message-queue)
```

###  Alternatives

[league/geotools

Geo-related tools PHP 7.3+ library

1.4k5.3M26](/packages/league-geotools)[amphp/parser

A generator parser to make streaming parsers simple.

14952.8M16](/packages/amphp-parser)[amphp/serialization

Serialization tools for IPC and data storage in PHP.

13451.1M18](/packages/amphp-serialization)[react/async

Async utilities and fibers for ReactPHP

2238.8M171](/packages/react-async)[amphp/pipeline

Asynchronous iterators and operators.

7432.7M34](/packages/amphp-pipeline)[react/promise-stream

The missing link between Promise-land and Stream-land for ReactPHP

11512.9M45](/packages/react-promise-stream)

PHPackages © 2026

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