WAMP

[ASKozienko]

Web Application Messaging Protocol (WAMP) Transport

A transport for Web Application Messaging Protocol.
WAMP is an open standard WebSocket subprotocol.
It uses internally Thruway PHP library voryx/thruway

Installation

$ composer require enqueue/wamp

Start the WAMP router

$ php vendor/voryx/thruway/Examples/SimpleWsRouter.php

Thruway is now running on 127.0.0.1 port 9090

Create context

<?php
use Enqueue\Wamp\WampConnectionFactory;

$connectionFactory = new WampConnectionFactory();

$context = $connectionFactory->createContext();

// if you have enqueue/enqueue library installed you can use a factory to build context from DSN 
$context = (new \Enqueue\ConnectionFactoryFactory())->create('wamp:')->createContext();

Consume message:

Start message consumer before send message to the topic

<?php
/** @var \Enqueue\Wamp\WampContext $context */

$fooTopic = $context->createTopic('foo');

$consumer = $context->createConsumer($fooQueue);

while (true) {
    if ($message = $consumer->receive()) {
        // process a message
    }
}

Subscription consumer

<?php
use Interop\Queue\Message;
use Interop\Queue\Consumer;

/** @var \Enqueue\Wamp\WampContext $context */
/** @var \Enqueue\Wamp\WampDestination $fooQueue */
/** @var \Enqueue\Wamp\WampDestination $barQueue */

$fooConsumer = $context->createConsumer($fooQueue);
$barConsumer = $context->createConsumer($barQueue);

$subscriptionConsumer = $context->createSubscriptionConsumer();
$subscriptionConsumer->subscribe($fooConsumer, function(Message $message, Consumer $consumer) {
    // process message
    
    return true;
});
$subscriptionConsumer->subscribe($barConsumer, function(Message $message, Consumer $consumer) {
    // process message
    
    return true;
});

$subscriptionConsumer->consume(2000); // 2 sec

Send message to topic

<?php
/** @var \Enqueue\Wamp\WampContext $context */

$fooTopic = $context->createTopic('foo');
$message = $context->createMessage('Hello world!');

$context->createProducer()->send($fooTopic, $message);

back to index

[makasim]

redis -> wamp

[makasim]

same here

[makasim]

could you use a concept from rdkafka transport (with a serializer interface)?

[makasim]

Copyright (c) 2018 Forma-Pro

[makasim]

`# Web Application Messaging Protocol (WAMP) Transport

[makasim]

We will have 100 clients in the context if we receive 100 message, right? Could we somehow reset them once a message has been received ?

[makasim]

Add docs, update readme.

[makasim]

add it to https://github.com/php-enqueue/enqueue-dev/blob/master/pkg/enqueue/Resources.php#L161

[makasim]

and here https://github.com/php-enqueue/enqueue-dev/blob/master/bin/subtree-split

[makasim]

resolve conflicts

[makasim]

https://github.com/php-enqueue/enqueue-dev/blob/master/phpunit.xml.dist - add wamp here

[makasim]

wamp and ws