PHPackages                             andrewbreksa/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. [Caching](/categories/caching)
4. /
5. andrewbreksa/rsmq

ActiveLibrary[Caching](/categories/caching)

andrewbreksa/rsmq
=================

Redis Simple Message Queue.

2.0.2(4y ago)3471.4k—6.1%5[6 PRs](https://github.com/abreksa4/php-rsmq/pulls)2MITPHPPHP ^7.4|^8.0

Since Aug 11Pushed 3y agoCompare

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

READMEChangelog (9)Dependencies (7)Versions (17)Used By (2)

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

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

[![Build Status](https://camo.githubusercontent.com/5d4d5f43c955286d81ac5fdd6125f316c170842432767979010257f8a01026be/68747470733a2f2f7472617669732d63692e636f6d2f616272656b7361342f7068702d72736d712e7376673f6272616e63683d6d6173746572)](https://travis-ci.com/abreksa4/php-rsmq)[![codecov](https://camo.githubusercontent.com/9ab19b6db2f9a29d5ff8448e1c89508f0d930dc772316f7ef2ccb72b4e015675/68747470733a2f2f636f6465636f762e696f2f67682f616272656b7361342f7068702d72736d712f6272616e63682f6d61737465722f67726170682f62616467652e737667)](https://codecov.io/gh/abreksa4/php-rsmq)[![License](https://camo.githubusercontent.com/f39fa05fa3c8128deafba233546c4d59e3423051dd7c72b84b5c6f3f3b9c31fc/68747470733a2f2f706f7365722e707567782e6f72672f616e647265776272656b73612f72736d712f6c6963656e7365)](//packagist.org/packages/andrewbreksa/rsmq)[![GitHub issues](https://camo.githubusercontent.com/9e8f45bb807b8a7950a2ef67ead161a49dd80bfa37741a3afc4b021bc1d28039/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f6973737565732f616272656b7361342f7068702d72736d71)](https://github.com/abreksa4/php-rsmq/issues)[![Latest Stable Version](https://camo.githubusercontent.com/c1fd81f8eb7dcbacc2c5033841ce1c793440f41707d1fcddd2dde40c1a3ff297/68747470733a2f2f706f7365722e707567782e6f72672f616e647265776272656b73612f72736d712f76)](//packagist.org/packages/andrewbreksa/rsmq)[![Latest Unstable Version](https://camo.githubusercontent.com/215dbf184aa0f50f84e62504266a91a025b91c4a93cf218facdf6eb7e48664d9/68747470733a2f2f706f7365722e707567782e6f72672f616e647265776272656b73612f72736d712f762f756e737461626c65)](//packagist.org/packages/andrewbreksa/rsmq)[![composer.lock](https://camo.githubusercontent.com/fccb71d39dd4bdbd47921fd38c5c8ab8e9d9e83fdf32382c4a8358f55259449b/68747470733a2f2f706f7365722e707567782e6f72672f616e647265776272656b73612f72736d712f636f6d706f7365726c6f636b)](//packagist.org/packages/andrewbreksa/rsmq)[![Total Downloads](https://camo.githubusercontent.com/592105cd94b6a0b8f6dbbd04a08eb6668f50d24c67076db563f8dcf0f25ad01e/68747470733a2f2f706f7365722e707567782e6f72672f616e647265776272656b73612f72736d712f646f776e6c6f616473)](//packagist.org/packages/andrewbreksa/rsmq)[![GitHub stars](https://camo.githubusercontent.com/3c40b9b377d8dc3ec58f9c2cf18476d30f5c5eae16f320f7cb98544edbad00a5/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f73746172732f616272656b7361342f7068702d72736d71)](https://github.com/abreksa4/php-rsmq/stargazers)[![Dependents](https://camo.githubusercontent.com/4c6cfdf86fb7d8dfea904cbdc4ed3076bc2feabc343817bc03aab95c78a0106a/68747470733a2f2f706f7365722e707567782e6f72672f616e647265776272656b73612f72736d712f646570656e64656e7473)](//packagist.org/packages/andrewbreksa/rsmq)

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 andrewbreksa/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:

```