Ntb\QueueAdapter\RedisAdapter
ANotificationMessage queue adapter for redis
- Author: Eduard Malyj <eduard.malyj@gmail.com>
Synopsis
class RedisAdapter
implements
IQueueAdapter
{
- // constants
- const DEFAULT_HOST = '127.0.0.1';
- const DEFAULT_PORT = 6379;
- const DEFAULT_SCHEME = 'tcp';
- // methods
- public void __construct()
- public void publish()
- public mixed read()
- public void clear()
- public IMessage|bool readInto()
Hierarchy
Implements
Constants
Name | Value |
---|---|
DEFAULT_HOST | '127.0.0.1' |
DEFAULT_PORT | 6379 |
DEFAULT_SCHEME | 'tcp' |
Members
protected
- $_options
- $_redis
—
\Predis\Client
Redis object
Methods
public
- __construct() — Constructor
- clear()
- publish() — Publishes a message into the redis queue
- read()
- readInto() — Reads data from a queue and stores the data into a given message. The message will be returned. If an error occurred or no data is provided, the method returns FALSE.