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

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

corley/queue
============

1.0.0(9y ago)12864MITPHP

Since Jan 21Pushed 9y agoCompare

[ Source](https://github.com/wdalmut/queue)[ Packagist](https://packagist.org/packages/corley/queue)[ RSS](/packages/corley-queue/feed)WikiDiscussions master Synced 4w ago

READMEChangelogDependencies (1)Versions (2)Used By (4)

Queue
=====

[](#queue)

Adaptable queue layers

[![Build Status](https://camo.githubusercontent.com/9516ab73f2591c096550edbb3c712451abf269daf04650ad72c424f2c0074515/68747470733a2f2f7472617669732d63692e6f72672f7764616c6d75742f71756575652e7376673f6272616e63683d6d6173746572)](https://travis-ci.org/wdalmut/queue)[![Scrutinizer Code Quality](https://camo.githubusercontent.com/79f4353f9f234b31dabf1baadc7cd73b1c3832660b63809738aad3edb37f4b20/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f7764616c6d75742f71756575652f6261646765732f7175616c6974792d73636f72652e706e673f623d6d6173746572)](https://scrutinizer-ci.com/g/wdalmut/queue/?branch=master)[![Code Coverage](https://camo.githubusercontent.com/025821c0f621bab0bf2119a798fe96747ec48e1454ecba4517dfc37c75e5aead/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f7764616c6d75742f71756575652f6261646765732f636f7665726167652e706e673f623d6d6173746572)](https://scrutinizer-ci.com/g/wdalmut/queue/?branch=master)

Create
------

[](#create)

```
$queue = new Queue("queue name", $queueAdapter);
```

[Check also the wiki](https://github.com/wdalmut/queue/wiki)

### Available Adapters

[](#available-adapters)

- AWS SQS
- RabbitMQ
- MySQL
- Internal array
- [*send an issue/pr to add your adapter here...*](#interface)

Receive from queue
------------------

[](#receive-from-queue)

```
list($receipt, $message) = $queue->receive();

// receive with options
list($receipt, $message) = $queue->receive(["timeout" => 15*60]);
```

Send in queue
-------------

[](#send-in-queue)

```
$queue->send("my message");

// send with options
$queue->send("my message", ["delay" => 20]);
```

Delete from queue
-----------------

[](#delete-from-queue)

```
$queue->delete($receipt);

// delete with options
$queue->delete($receipt, ["delay" => 20]);
```

Manage different adapters options
---------------------------------

[](#manage-different-adapters-options)

Just use functions

```
$queue = new Queue("https://sqs.amazon.com/39857/urs", $sqsAdapter);
$queue->send("message", toSQS(["delay" => 20]));

function toSQS(array options = []) {
    $opts = [];
    if (array_key_exists("delay", $options)) {
        $opts["DelaySeconds"] = $options["delay"];
    }
    return $opts;
}
```

Queue Interface (for adapters)
====================================================================

[](#queue-interface-for-adapters-)

You have to implement 3 methods from `Corley\Queue\QueueInterface`

```
public function send($queueName, $message, array $options);
public function receive($queueName, array $options);
public function delete($queueName, $receipt, array $options);
```

Tips on return values (`receive` message)
=========================================

[](#tips-on-return-values-receive-message)

As you can see the return value

- The send operation should return the queue send operation status
- The receive *MUST* return an array where the first parameter is the message receipt that is need for the remove operation
- The delete operation should return the queue delete operation status

###  Health Score

29

—

LowBetter than 57% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity13

Limited adoption so far

Community11

Small or concentrated contributor base

Maturity63

Established project with proven stability

 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

Unknown

Total

1

Last Release

3447d ago

### Community

Maintainers

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

---

Top Contributors

[![wdalmut](https://avatars.githubusercontent.com/u/551974?v=4)](https://github.com/wdalmut "wdalmut (6 commits)")

---

Tags

queuequeueingrabbitmqrabbitmq-clientsqssqs-interfacesqs-queue

###  Code Quality

TestsPHPUnit

### Embed Badge

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

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

###  Alternatives

[league/geotools

Geo-related tools PHP 7.3+ library

1.4k5.5M30](/packages/league-geotools)[illuminate/bus

The Illuminate Bus package.

6045.5M508](/packages/illuminate-bus)[uecode/qpush-bundle

Asynchronous processing for Symfony using Push Queues

1672.5M2](/packages/uecode-qpush-bundle)[jayazhao/think-queue-rabbitmq

为 ThinkPHP5.1 队列增加 RabbitMQ 驱动

141.5k](/packages/jayazhao-think-queue-rabbitmq)[mayconbordin/l5-stomp-queue

Stomp Queue Driver for Laravel 5

121.1k](/packages/mayconbordin-l5-stomp-queue)

PHPackages © 2026

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