PHPackages                             jellelampaert/ci4\_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. jellelampaert/ci4\_queue

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

jellelampaert/ci4\_queue
========================

CodeIgniter4 queuing system

v0.1(4y ago)06MITPHPPHP ^7.3 || ^8.0

Since Feb 2Pushed 4y ago1 watchersCompare

[ Source](https://github.com/jellelampaert/ci4_queue)[ Packagist](https://packagist.org/packages/jellelampaert/ci4_queue)[ RSS](/packages/jellelampaert-ci4-queue/feed)WikiDiscussions main Synced today

READMEChangelog (1)Dependencies (1)Versions (2)Used By (0)

CodeIgniter4 queuing system
===========================

[](#codeigniter4-queuing-system)

Queue tasks that depend on external services (like e-mail) in the database. Process the queue asynchronous (i.e. by using a cronjob), so the user does not have to wait for that service to respond.

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

[](#installation)

Install the package through [Composer](http://getcomposer.org/).

Run the Composer require command from the Terminal:

```
composer require jellelampaert/ci4_queue

```

Once installed, make sure your database is setup correctly and run the migration

```
php spark migrate -all

```

Usage
-----

[](#usage)

How to load the library

```
$queue = new \jellelampaert\ci4_queue\Queue();
$queue->queue('email')->add(array(
    'to'        => 'test@example.com',
    'subject'   => 'This is a test',
    'message'   => 'Testing, attention please'
));
```

The queuing system has the following methods:

### Queue::queue($queue)

[](#queuequeuequeue)

Define the queue you want to use. Your application can have different queues, i.e. a queue for e-mails, a queue for webhooks, ...

### Queue::add($data)

[](#queueadddata)

Add a task to the queue. The argument can be anything: a number, a string, an array, an object, ... Make sure to define a queuename first

```
$queue = new Queue();
$queue->queue('email')->add(array(
    'to'        => 'test@example.com',
    'subject'   => 'This is a test',
    'message'   => 'Testing, attention please'
));
```

### Queue::clean($hours)

[](#queuecleanhours)

Delete all tasks from a queue that are processed more than x hours ago.

```
$queue = new Queue();
$queue->queue('email')->clean(24);
```

### Queue::cleanAll($hours)

[](#queuecleanallhours)

Delete all tasks from all queues that are processed more than x hours ago.

```
$queue = new Queue();
$queue->cleanAll(24);
```

### Queue::delete($id)

[](#queuedeleteid)

Delete a task from the database.

```
$queue = new Queue();
$queue->delete(1);
```

### Queue::getAllTasks()

[](#queuegetalltasks)

Gets all tasks in the queue, whether they are processed or not

```
$queue = new Queue();
$queue->queue('email')->getAllTasks();
```

### Queue::getAllUnprocessed()

[](#queuegetallunprocessed)

Gets all unprocessed tasks from every queue in the database.

```
$queue = new Queue();
$queue->getAllUnprocessed();
```

### Queue::getTask($id)

[](#queuegettaskid)

Gets a task by it's ID

```
$queue = new Queue();
$queue->getTask(1);
```

### Queue::getUnprocessed()

[](#queuegetunprocessed)

Get all unprocessed tasks from a queue.

```
$queue = new Queue();
$queue->queue('email')->getUnprocessed();
```

### Queue::setProcessed($id)

[](#queuesetprocessedid)

Sets a task as processed.

```
$queue = new Queue();
$queue->queue('email')->setProcessed(1);
```

### Queue::setResponse($id, $data)

[](#queuesetresponseid-data)

Sets the response of a task. This can be used for logging purposes or debugging

```
$queue = new Queue();
$queue->setResponse(1, 'HTTP Error 404');
```

License
-------

[](#license)

This package is free software distributed under the terms of the [MIT license](LICENSE.md).

###  Health Score

20

—

LowBetter than 14% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity4

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity43

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

Unknown

Total

1

Last Release

1556d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/45a5dcf3938171b0e568c3ee655ad9dce76b456f0e836be83de9f06dd0a0473a?d=identicon)[JelleLampaert](/maintainers/JelleLampaert)

---

Top Contributors

[![jellelampaert](https://avatars.githubusercontent.com/u/3541955?v=4)](https://github.com/jellelampaert "jellelampaert (1 commits)")

---

Tags

queuecodeigniter4

### Embed Badge

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

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

###  Alternatives

[php-amqplib/php-amqplib

Formerly videlalvaro/php-amqplib. This library is a pure PHP implementation of the AMQP protocol. It's been tested against RabbitMQ.

4.6k125.3M871](/packages/php-amqplib-php-amqplib)[ramsey/collection

A PHP library for representing and manipulating collections.

1.2k486.0M69](/packages/ramsey-collection)[queue-interop/queue-interop

Promoting the interoperability of MQs objects. Based on Java JMS

48030.5M86](/packages/queue-interop-queue-interop)[enqueue/enqueue

Message Queue Library

19820.0M56](/packages/enqueue-enqueue)[phootwork/collection

The phootwork library fills gaps in the php language and provides better solutions than the existing ones php offers.

3924.8M15](/packages/phootwork-collection)[apinstein/jqjobs

Async job manager for PHP.

3220.2k](/packages/apinstein-jqjobs)

PHPackages © 2026

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