The li3_queue from unionofrad

AMQPS (SSL) Support

I have used this library for some time now but have recently moved our RabbitMQ servers and now wish to communicate over AMQPS. After a quick search I have found nothing relating to AMQPS, SSL or certificates in this repository and after searching the Lithium repository I didn't find anything there that helps me either. Am I missing something or does Lithium not actually have SSL networking capability? In which case this should probably be a Lithium issue.

README

Are there plans for a readme explaining the usage of this library?

Seems potentially useful but I cant be sure unless I the time to investigate the code...

implement pub/sub with ampq

@markwilde any suggestion to implement pub/sub for ampq adapter, for each queue in ampq class should generate new uniq queue ;/ there is impossible i think with actual configuration

@link https://www.rabbitmq.com/tutorials/tutorial-three-php.html

i did workaround for pub/sub with config:

use li3_queue\storage\Queue;

Queue::config(array(
    'li3.publisher' => array(
        'adapter' => 'AMQP',
        'host' => 'localhost',
        'port' => 5672,
        'user' => 'guest',
        'pass' => 'guest',
        'vhost' => '/',
        'exchange' => 'amq.fanout',
        'queue' => 'li3.events.1',
        'routingKey' => 'li3.events',
        'autoConfirm' => false,
        'readTimeout' => 0,
        'type' => AMQP_EX_TYPE_FANOUT,
        'prefetchCount' => 1
    ),
    'li3.subscriber.1' => array( #same like publisher jus for clarify
        'adapter' => 'AMQP',
        'host' => 'localhost',
        'port' => 5672,
        'user' => 'guest',
        'pass' => 'guest',
        'vhost' => '/',
        'exchange' => 'amq.fanout',
        'queue' => 'li3.events.1',
        'routingKey' => 'li3.events',
        'autoConfirm' => false,
        'readTimeout' => 0,
        'type' => AMQP_EX_TYPE_FANOUT,
        'prefetchCount' => 1
    ),
    'li3.subscriber.2' => array(
        'adapter' => 'AMQP',
        'host' => 'localhost',
        'port' => 5672,
        'user' => 'guest',
        'pass' => 'guest',
        'vhost' => '/',
        'exchange' => 'amq.fanout',
        'queue' => 'li3.events.2',
        'routingKey' => 'li3.events',
        'autoConfirm' => false,
        'readTimeout' => 0,
        'type' => AMQP_EX_TYPE_FANOUT,
        'prefetchCount' => 1
    )
));

publish evets

Queue::write('li3.publisher', json_encode(['model' => 'Users', 'method' => 'save', 'id' => $entity->user_id] + compact('options')));

two consumers # - 1,2 receive same event info eg

{"model":"Users","method":"save","id":"4023","options":{"validate":false,"whitelist":["profile_id"]}}

Queue::consume('li3.subscriber.#', function($message) {
            sleep(2);
            $this->out($message->data());
            //$message->confirm();
            //if (false) {
                // Confirm message
                $message->confirm();
            //}
            // Requeue message
            //$message->requeue();
        });

unionofrad / li3_queue Goto Github PK

li3_queue's People

Contributors

Stargazers

Watchers

Forkers

li3_queue's Issues

AMQPS (SSL) Support

README

implement pub/sub with ampq

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent