pekkis / queue
Queue abstraction library
Installs: 128 921
Dependents: 2
Suggesters: 0
Security: 0
Stars: 18
Watchers: 4
Forks: 7
Open Issues: 1
Requires
- php: >=7.1
- aws/aws-sdk-php: ~3.2
- iron-io/iron_mq: ~4.0
- php-amqplib/php-amqplib: ~2.5
- ramsey/uuid: ^3.8
- symfony/console: ~3.4|~4.0
- symfony/event-dispatcher: ~3.4|~4.0
Requires (Dev)
- phpunit/phpunit: ^7.3
README
A small, opinionated queue abstraction library based on discovered needs. Extracted from Xi Filelib and other assorted projects.
What does it do?
A message consists of a topic and arbitrary data (basic serializable data supported by default, custom serializers can be added). Messages are moved and grooved through a queue. The library extracts a simple, 80/20 like domain for it's method of operation and abstracts away the differences in message queue backends.
Status
The project is purely in maintenance mode. I have "moved on" since, code mostly JS & React these days.
If you want to maintain this, holler!
Quickstart
<?php namespace Pekkis\Queue\Example; use Pekkis\Queue\Adapter\IronMQAdapter; use Pekkis\Queue\Message; use Pekkis\Queue\Queue; require_once (is_file(__DIR__ . '/bootstrap.php')) ? __DIR__ . '/bootstrap.php' : __DIR__ . '/bootstrap.dist.php'; // Create a new IronMQ backed queue $queue = new Queue( new IronMQAdapter(IRONMQ_TOKEN, IRONMQ_PROJECT_ID, 'pekkis-queue-example') ); // Queues can be emptied. $queue->purge(); // A message consists of a topic and data. A message instance with an UUID you can use is returned. $message = $queue->enqueue( 'pekkis.queue.example', array( 'some' => 'random data' ) ); // Dequeue and process a single message $received = $queue->dequeue(); $data = $received->getData(); var_dump($data); // Acknowledge the message (you're done with it) $queue->ack($received);
A better example
For an end-to-end example with IronMQ and a "real life" scenario, see the folder examples
.
Also see Xi Filelib (v0.10+) for actual real use case from the real world!
Ideas / wishes? Contact or create a pull request! Cheers!
Supported queues
- RabbitMQ (via PECL and pure PHP).
- IronMQ
- Amazon SQS
Version upgrades
Refer to the change log