README

##概述此扩展允许您通过简单地标记您的服务和依赖Symfony的事件调度器来轻松消费推送队列中的消息，无需运行守护程序或后台进程以持续轮询您的队列。

##安装

应通过composer安装此扩展。

####将扩展添加到您的composer.json文件中

{
    "require": {
        "uecode/qpush-bundle": "~2.1.0",
    }
}

####更新您的Symfony应用的AppKernel.php

将UecodeQPushBundle添加到内核引导序列中的$bundles数组。

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

    return $bundles;
}

##基本配置

以下是一个基本配置示例，该配置使用AWS或IronMQ创建了一个名为my_queue_name的推送队列。您可以在完整文档中了解支持的提供者和提供者选项。

######示例

#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 }

##向队列发布消息

发布消息很简单 - 从容器中获取已注册的Provider服务，并在相应的队列上调用publish方法。

此扩展将您的消息存储为json对象，并期望publish方法接收一个数组，通常是关联数组。

######示例

// 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);
}

##处理队列中的消息

当消息到达您的应用程序时，此扩展将调度一个MessageEvent，这些事件可以由您的服务处理。您需要标记您的服务来处理这些事件。

######示例

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

######示例

// 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
}

Message对象包含提供者特定的消息ID、消息体和提供者特定的元数据集合。

这些属性可以通过消息对象上的简单getter访问。

######示例

// 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
}

###清理队列

一旦所有其他MessageEvent的事件监听器都被调用，扩展将自动尝试为您从队列中删除消息。

tahoelimited / qpush-bundle

维护者

详细信息

README