PHPackages                             chickentom888/rsmq - 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. chickentom888/rsmq

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

chickentom888/rsmq
==================

Redis Simple Message Queue.

00PHP

Since Apr 20Pushed 3y ago1 watchersCompare

[ Source](https://github.com/chickentom888/php-rsmq)[ Packagist](https://packagist.org/packages/chickentom888/rsmq)[ RSS](/packages/chickentom888-rsmq/feed)WikiDiscussions main Synced 1mo ago

READMEChangelogDependenciesVersions (1)Used By (0)

Redis Simple Message Queue
--------------------------

[](#redis-simple-message-queue)

A lightweight message queue for PHP that requires no dedicated queue server. Just a Redis server. See [smrchy/rsmq](https://github.com/smrchy/rsmq) for more information.

This is a fork of [eislambey/php-rsmq](https://github.com/eislambey/php-rsmq) with the following changes:

- Uses [predis](https://github.com/nrk/predis) instead of the Redis extension
- Has some OO wrappers for QueueAttributes and Message
- Provides a simple [QueueWorker](./src/QueueWorker.php)

Table of Contents
=================

[](#table-of-contents)

- [Installation](#installation)
- [Methods](#methods)
    - [Construct](#construct)
    - [Queue](#queue)
        - [createQueue](#createqueue)
        - [listQueues](#listqueues)
        - [deleteQueue](#deletequeue)
        - [getQueueAttributes](#getqueueattributes)
        - [setQueueAttributes](#setqueueattributes)
    - [Messages](#messages)
        - [sendMessage](#sendmessage)
        - [receiveMessage](#receivemessage)
        - [deleteMessage](#deletemessage)
        - [popMessage](#popmessage)
        - [changeMessageVisibility](#changemessagevisibility)
    - [Realtime](#realtime)
- [QueueWorker](#queueworker)
- [LICENSE](#license)

Installation
============

[](#installation)

```
composer require chickentom888/php-rsmq

```

Methods
=======

[](#methods)

Construct
---------

[](#construct)

Creates a new instance of RSMQ.

Parameters:

- `$predis` (\\Predis\\ClientInterface): \*required The Predis instance
- `$ns` (string): *optional (Default: "rsmq")* The namespace prefix used for all keys created by RSMQ
- `$realtime` (Boolean): *optional (Default: false)* Enable realtime PUBLISH of new messages

Example:

```