uecode/qpush-bundle

Asynchronous processing for Symfony using Push Queues

3.0.2 2018-08-13 17:01 UTC

Requires

• php: >=5.6.0
• doctrine/common: ~2.4
• symfony/config: ~2.3|^3.0|^4.0
• symfony/console: ~2.3|^3.0|^4.0
• symfony/dependency-injection: ~2.3|^3.0|^4.0
• symfony/http-kernel: ~2.3|^3.0|^4.0
• symfony/monolog-bundle: ~2.3|^3.0|^4.0

Requires (Dev)

• aws/aws-sdk-php: ~2.5
• doctrine/orm: ^2.4.8
• iron-io/iron_mq: ^4.0
• stof/doctrine-extensions-bundle: ^1.2
• symfony/filesystem: ~2.3|^3.0|^4.0
• symfony/finder: ~2.3|^3.0|^4.0
• symfony/phpunit-bridge: ^4.0
• symfony/yaml: ~2.8|^3.0|^4.0

Suggests

• aws/aws-sdk-php: Required to use AWS as a Queue Provider
• doctrine/orm: Required to use Doctrine as a Queue Provider
• iron-io/iron_mq: Required to use IronMQ as a Queue Provider
• stof/doctrine-extensions-bundle: Required to use Doctrine as a Queue Provider
• symfony/filesystem: Required to use File as a Queue Provider
• symfony/finder: Required to use File as a Queue Provider

Apache-2.0

• Keith Kirk

• symfony
• bundle
• aws
• push
• qpush
• pub-sub
• asynch
• iron mq

README

Overview

This bundle allows you to easily consume messages from Push Queues by simply tagging your services and relying on Symfony's event dispatcher - without needing to run a daemon or background process to continuously poll your queue.

Full Documentation: qpush-bundle.readthedocs.org

Installation

The bundle should be installed through composer.

composer require uecode/qpush-bundle

Update AppKernel.php of your Symfony Application

Add the UecodeQPushBundle to your kernel bootstrap sequence, in the $bundles array.

public function registerBundles()
{
    $bundles = array(
        // ...
        new Uecode\Bundle\QPushBundle\UecodeQPushBundle(),
    );

    return $bundles;
}

Basic Configuration:

Here is a basic configuration that would create a push queue called my_queue_name using AWS or IronMQ. You can read about the supported providers and provider options in the full documentation.

Example

#app/config.yml

uecode_qpush:
    providers:
        ironmq:
            token:      YOUR_IRON_MQ_TOKEN_HERE
            project_id: YOUR_IRON_MQ_PROJECT_ID_HERE
        aws:
            key:    YOUR_AWS_KEY_HERE
            secret: YOUR_AWS_SECRET_HERE
            region: YOUR_AWS_REGION_HERE
    queues:
        my_queue_key:
            provider: ironmq #or aws
            options:
                queue_name: my_queue_name #optional. the queue name used on the provider
                push_notifications: true
                subscribers:
                    - { endpoint: http://example.com/qpush, protocol: http }

You may exclude aws key and secret to default to IAM role on the EC2 machine.

Publishing messages to your Queue

Publishing messages is simple - fetch the registered Provider service from the container and call the publish method on the respective queue.

This bundle stores your messages as a json object and the publish method expects an array, typically associative.

Example

// src/My/Bundle/ExampleBundle/Controller/MyController.php

public function publishAction()
{
    $message = ['foo' => 'bar'];

    // fetch your provider service from the container
    $this->get('uecode_qpush')->get('my_queue_key')->publish($message);

    // you can also fetch it directly
    $this->get('uecode_qpush.my_queue_key')->publish($message);
}

Working with messages from your Queue

When a message hits your application, this bundle will dispatch a MessageEvent which can be handled by your services. You need to tag your services to handle these events.

Example

services:
    my_example_service:
    	class: My\Bundle\ExampleBundle\Service\ExampleService
    	tags:
    		- { name: uecode_qpush.event_listener, event: my_queue_key.message_received, method: onMessageReceived }

Example

// src/My/Bundle/ExampleBundle/Service/ExampleService.php

use Uecode\Bundle\QPushBundle\Event\MessageEvent;

public function onMessageReceived(MessageEvent $event)
{
    $queue_name = $event->getQueueName();
    $message    = $event->getMessage();

    // do some processing
}

The Message objects contain the provider specific message id, a message body, and a collection of provider specific metadata.

These properties are accessible through simple getters from the message object.

Example

// src/My/Bundle/ExampleBundle/Service/ExampleService.php

use Uecode\Bundle\QPushBundle\Event\MessageEvent;
use Uecode\Bundle\QPushBundle\Message\Message;

public function onMessageReceived(MessageEvent $event)
{
    $id         = $event->getMessage()->getId();
    $body       = $event->getMessage()->getBody();
    $metadata   = $event->getMessage()->getMetadata();

    // do some processing
}

Cleaning up the Queue

Once all other Event Listeners have been invoked on a MessageEvent, the Bundle will automatically attempt to remove the Message from your Queue for you.