wamp

Author: ASKozienko

bin/subtree-split

@@ -66,6 +66,7 @@ remote async-event-dispatcher [email protected]:php-enqueue/async-event-dispatcher.
 remote async-command [email protected]:php-enqueue/async-command.git
 remote mongodb [email protected]:php-enqueue/mongodb.git
 remote dsn [email protected]:php-enqueue/dsn.git
+remote wamp [email protected]:php-enqueue/wamp.git
 
 split 'pkg/enqueue' enqueue
 split 'pkg/simple-client' simple-client
@@ -90,3 +91,4 @@ split 'pkg/async-event-dispatcher' async-event-dispatcher
 split 'pkg/async-command' async-command
 split 'pkg/mongodb' mongodb
 split 'pkg/dsn' dsn
+split 'pkg/wamp' wamp

docs/index.md

@@ -10,6 +10,7 @@
     - [Kafka](transport/kafka.md)
     - [Stomp](transport/stomp.md)
     - [Redis](transport/redis.md)
+    - [Wamp](transport/wamp.md)
     - [Doctrine DBAL](transport/dbal.md)
     - [Filesystem](transport/filesystem.md)
     - [Null](transport/null.md)

docs/transport/wamp.md

@@ -0,0 +1,73 @@
+# Web Application Messaging Protocol (WAMP) Transport
+
+A transport for [Web Application Messaging Protocol](https://wamp-proto.org/).
+WAMP is an open standard WebSocket subprotocol.
+It uses internally Thruway PHP library [voryx/thruway](https://github.com/voryx/Thruway) 
+
+* [Installation](#installation)
+* [Start the WAMP router](#start-the-wamp-router)
+* [Create context](#create-context)
+* [Consume message](#consume-message)
+* [Send message to topic](#send-message-to-topic)
+
+## Installation
+
+```bash
+$ composer require enqueue/wamp
+```
+
+## Start the WAMP router
+
+```bash
+$ php vendor/voryx/thruway/Examples/SimpleWsRouter.php
+```
+
+Thruway is now running on 127.0.0.1 port 9090 
+
+
+## Create context
+
+```php
+<?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
+<?php
+/** @var \Enqueue\Wamp\WampContext $context */
+
+$fooTopic = $context->createTopic('foo');
+
+$consumer = $context->createConsumer($fooQueue);
+
+while (true) {
+    if ($message = $consumer->receive()) {
+        // process a message
+    }
+}
+```
+
+## Send message to topic
+
+```php
+<?php
+/** @var \Enqueue\Wamp\WampContext $context */
+
+$fooTopic = $context->createTopic('foo');
+$message = $context->createMessage('Hello world!');
+
+$context->createProducer()->send($fooTopic, $message);
+```
+
+[back to index](../index.md)

pkg/enqueue/Resources.php

@@ -16,6 +16,7 @@
 use Enqueue\Redis\RedisConnectionFactory;
 use Enqueue\Sqs\SqsConnectionFactory;
 use Enqueue\Stomp\StompConnectionFactory;
+use Enqueue\Wamp\WampConnectionFactory;
 use Interop\Queue\ConnectionFactory;
 
 final class Resources
@@ -163,6 +164,11 @@ public static function getKnownConnections(): array
                 'supportedSchemeExtensions' => [],
                 'package' => 'enqueue/mongodb',
             ];
+            $map[WampConnectionFactory::class] = [
+                'schemes' => ['wamp'],
+                'supportedSchemeExtensions' => [],
+                'package' => 'enqueue/wamp',
+            ];
 
             self::$knownConnections = $map;
         }