.github/workflows/ci.yml

@@ -0,0 +1,27 @@
+name: CI
+on:
+  pull_request:
+  push:
+    branches:
+      - master
+jobs:
+  tests:
+    runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        php: ['7.4', '8.0', '8.1', '8.2']
+
+    name: PHP ${{ matrix.php }} tests
+
+    steps:
+      - uses: actions/checkout@v2
+
+      - uses: shivammathur/setup-php@v2
+        with:
+          php-version: ${{ matrix.php }}
+          coverage: none
+
+      - uses: "ramsey/composer-install@v1"
+
+      - run: vendor/bin/phpunit --exclude-group=functional

JsonSerializer.php

@@ -14,12 +14,8 @@ public function toString(WampMessage $message): string
             'headers' => $message->getHeaders(),
         ]);
 
-        if (JSON_ERROR_NONE !== json_last_error()) {
-            throw new \InvalidArgumentException(sprintf(
-                'The malformed json given. Error %s and message %s',
-                json_last_error(),
-                json_last_error_msg()
-            ));
+        if (\JSON_ERROR_NONE !== json_last_error()) {
+            throw new \InvalidArgumentException(sprintf('The malformed json given. Error %s and message %s', json_last_error(), json_last_error_msg()));
         }
 
         return $json;
@@ -28,12 +24,8 @@ public function toString(WampMessage $message): string
     public function toMessage(string $string): WampMessage
     {
         $data = json_decode($string, true);
-        if (JSON_ERROR_NONE !== json_last_error()) {
-            throw new \InvalidArgumentException(sprintf(
-                'The malformed json given. Error %s and message %s',
-                json_last_error(),
-                json_last_error_msg()
-            ));
+        if (\JSON_ERROR_NONE !== json_last_error()) {
+            throw new \InvalidArgumentException(sprintf('The malformed json given. Error %s and message %s', json_last_error(), json_last_error_msg()));
         }
 
         return new WampMessage($data['body'], $data['properties'], $data['headers']);

README.md

@@ -10,27 +10,27 @@ Enqueue is an MIT-licensed open source project with its ongoing development made
 # Web Application Messaging Protocol (WAMP) Transport
 
 [![Gitter](https://badges.gitter.im/php-enqueue/Lobby.svg)](https://gitter.im/php-enqueue/Lobby)
-[![Build Status](https://travis-ci.org/php-enqueue/wamp.png?branch=master)](https://travis-ci.org/php-enqueue/wamp)
+[![Build Status](https://img.shields.io/github/actions/workflow/status/php-enqueue/wamp/ci.yml?branch=master)](https://github.com/php-enqueue/wamp/actions?query=workflow%3ACI)
 [![Total Downloads](https://poser.pugx.org/enqueue/wamp/d/total.png)](https://packagist.org/packages/enqueue/wamp)
 [![Latest Stable Version](https://poser.pugx.org/enqueue/wamp/version.png)](https://packagist.org/packages/enqueue/wamp)
- 
-This is an implementation of [queue interop](https://github.com/queue-interop/queue-interop). It uses [Thruway](https://github.com/voryx/Thruway) internally.  
+
+This is an implementation of [queue interop](https://github.com/queue-interop/queue-interop). It uses [Thruway](https://github.com/thruway/client) internally.
 
 ## Resources
 
 * [Site](https://enqueue.forma-pro.com/)
-* [Documentation](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/index.md)
+* [Documentation](https://php-enqueue.github.io/transport/wamp/)
 * [Questions](https://gitter.im/php-enqueue/Lobby)
 * [Issue Tracker](https://github.com/php-enqueue/enqueue-dev/issues)
 
 ## Developed by Forma-Pro
 
-Forma-Pro is a full stack development company which interests also spread to open source development. 
-Being a team of strong professionals we have an aim an ability to help community by developing cutting edge solutions in the areas of e-commerce, docker & microservice oriented architecture where we have accumulated a huge many-years experience. 
+Forma-Pro is a full stack development company which interests also spread to open source development.
+Being a team of strong professionals we have an aim an ability to help community by developing cutting edge solutions in the areas of e-commerce, docker & microservice oriented architecture where we have accumulated a huge many-years experience.
 Our main specialization is Symfony framework based solution, but we are always looking to the technologies that allow us to do our job the best way. We are committed to creating solutions that revolutionize the way how things are developed in aspects of architecture & scalability.
 
 If you have any questions and inquires about our open source development, this product particularly or any other matter feel free to contact at opensource@forma-pro.com
 
 ## License
 
-It is released under the [MIT License](LICENSE).
+It is released under the [MIT License](LICENSE).

SerializerAwareTrait.php

@@ -11,9 +11,6 @@ trait SerializerAwareTrait
      */
     private $serializer;
 
-    /**
-     * @param Serializer $serializer
-     */
     public function setSerializer(Serializer $serializer)
     {
         $this->serializer = $serializer;

Tests/Functional/WampConsumerTest.php

@@ -12,14 +12,15 @@
 /**
  * @group functional
  * @group Wamp
+ *
  * @retry 5
  */
 class WampConsumerTest extends TestCase
 {
-    use WampExtension;
     use RetryTrait;
+    use WampExtension;
 
-    public static function setUpBeforeClass()
+    public static function setUpBeforeClass(): void
     {
         Logger::set(new NullLogger());
     }

Tests/Functional/WampSubscriptionConsumerTest.php

@@ -16,7 +16,7 @@ class WampSubscriptionConsumerTest extends TestCase
 {
     use WampExtension;
 
-    public static function setUpBeforeClass()
+    public static function setUpBeforeClass(): void
     {
         Logger::set(new NullLogger());
     }

Tests/Spec/JsonSerializerTest.php

@@ -20,11 +20,6 @@ public function testShouldImplementSerializerInterface()
         $this->assertClassImplements(Serializer::class, JsonSerializer::class);
     }
 
-    public function testCouldBeConstructedWithoutAnyArguments()
-    {
-        new JsonSerializer();
-    }
-
     public function testShouldConvertMessageToJsonString()
     {
         $serializer = new JsonSerializer();
@@ -40,10 +35,10 @@ public function testThrowIfFailedToEncodeMessageToJson()
     {
         $serializer = new JsonSerializer();
 
-        $resource = fopen(__FILE__, 'rb');
+        $resource = fopen(__FILE__, 'r');
 
-        //guard
-        $this->assertInternalType('resource', $resource);
+        // guard
+        $this->assertIsResource($resource);
 
         $message = new WampMessage('theBody', ['aProp' => $resource]);
 

Tests/Spec/WampConnectionFactoryTest.php

@@ -10,9 +10,6 @@
  */
 class WampConnectionFactoryTest extends ConnectionFactorySpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createConnectionFactory()
     {
         return new WampConnectionFactory();

Tests/Spec/WampContextTest.php

@@ -13,9 +13,6 @@ class WampContextTest extends ContextSpec
 {
     use WampExtension;
 
-    /**
-     * {@inheritdoc}
-     */
     protected function createContext()
     {
         return $this->buildWampContext();

Tests/Spec/WampMessageTest.php

@@ -10,9 +10,6 @@
  */
 class WampMessageTest extends MessageSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createMessage()
     {
         return new WampMessage();

Tests/Spec/WampProducerTest.php

@@ -13,9 +13,6 @@ class WampProducerTest extends ProducerSpec
 {
     use WampExtension;
 
-    /**
-     * {@inheritdoc}
-     */
     protected function createProducer()
     {
         return $this->buildWampContext()->createProducer();

Tests/Spec/WampQueueTest.php

@@ -10,9 +10,6 @@
  */
 class WampQueueTest extends QueueSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createQueue()
     {
         return new WampDestination(self::EXPECTED_QUEUE_NAME);

Tests/Spec/WampTopicTest.php

@@ -10,9 +10,6 @@
  */
 class WampTopicTest extends TopicSpec
 {
-    /**
-     * {@inheritdoc}
-     */
     protected function createTopic()
     {
         return new WampDestination(self::EXPECTED_TOPIC_NAME);

WampConnectionFactory.php

@@ -88,10 +88,7 @@ private function parseDsn(string $dsn): array
         $dsn = Dsn::parseFirst($dsn);
 
         if (false === in_array($dsn->getSchemeProtocol(), ['wamp', 'ws'], true)) {
-            throw new \LogicException(sprintf(
-                'The given scheme protocol "%s" is not supported. It must be "wamp"',
-                $dsn->getSchemeProtocol()
-            ));
+            throw new \LogicException(sprintf('The given scheme protocol "%s" is not supported. It must be "wamp"', $dsn->getSchemeProtocol()));
         }
 
         return array_filter(array_replace($dsn->getQuery(), [

WampConsumer.php

@@ -84,7 +84,7 @@ public function receive(int $timeout = 0): ?Message
         }
 
         if ($timeout > 0) {
-            $timeout = $timeout / 1000;
+            $timeout /= 1000;
             $timeout = $timeout >= 0.1 ? $timeout : 0.1;
 
             $this->timer = $this->client->getLoop()->addTimer($timeout, function () {
@@ -112,8 +112,6 @@ public function receiveNoWait(): ?Message
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param WampMessage $message
      */
     public function acknowledge(Message $message): void
@@ -122,8 +120,6 @@ public function acknowledge(Message $message): void
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param WampMessage $message
      */
     public function reject(Message $message, bool $requeue = false): void

WampContext.php

@@ -97,11 +97,7 @@ public function getNewClient(): Client
         $client = call_user_func($this->clientFactory);
 
         if (false == $client instanceof Client) {
-            throw new \LogicException(sprintf(
-                'The factory must return instance of "%s". But it returns %s',
-                Client::class,
-                is_object($client) ? get_class($client) : gettype($client)
-            ));
+            throw new \LogicException(sprintf('The factory must return instance of "%s". But it returns %s', Client::class, is_object($client) ? $client::class : gettype($client)));
         }
 
         $this->clients[] = $client;

WampProducer.php

@@ -48,8 +48,6 @@ public function __construct(WampContext $context)
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param WampDestination $destination
      * @param WampMessage     $message
      */
@@ -113,11 +111,9 @@ public function send(Destination $destination, Message $message): void
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @return WampProducer
      */
-    public function setDeliveryDelay(int $deliveryDelay = null): Producer
+    public function setDeliveryDelay(?int $deliveryDelay = null): Producer
     {
         if (null === $deliveryDelay) {
             return $this;
@@ -132,11 +128,9 @@ public function getDeliveryDelay(): ?int
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @return WampProducer
      */
-    public function setPriority(int $priority = null): Producer
+    public function setPriority(?int $priority = null): Producer
     {
         if (null === $priority) {
             return $this;
@@ -151,11 +145,9 @@ public function getPriority(): ?int
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @return WampProducer
      */
-    public function setTimeToLive(int $timeToLive = null): Producer
+    public function setTimeToLive(?int $timeToLive = null): Producer
     {
         if (null === $timeToLive) {
             return $this;

WampSubscriptionConsumer.php

@@ -84,7 +84,7 @@ public function consume(int $timeout = 0): void
         }
 
         if ($timeout > 0) {
-            $timeout = $timeout / 1000;
+            $timeout /= 1000;
             $timeout = $timeout >= 0.1 ? $timeout : 0.1;
 
             $this->timer = $this->client->getLoop()->addTimer($timeout, function () {
@@ -100,14 +100,12 @@ public function consume(int $timeout = 0): void
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param WampConsumer $consumer
      */
     public function subscribe(Consumer $consumer, callable $callback): void
     {
         if (false == $consumer instanceof WampConsumer) {
-            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', WampConsumer::class, get_class($consumer)));
+            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', WampConsumer::class, $consumer::class));
         }
 
         if ($this->client) {
@@ -127,14 +125,12 @@ public function subscribe(Consumer $consumer, callable $callback): void
     }
 
     /**
-     * {@inheritdoc}
-     *
      * @param WampConsumer $consumer
      */
     public function unsubscribe(Consumer $consumer): void
     {
         if (false == $consumer instanceof WampConsumer) {
-            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', WampConsumer::class, get_class($consumer)));
+            throw new \InvalidArgumentException(sprintf('The consumer must be instance of "%s" got "%s"', WampConsumer::class, $consumer::class));
         }
 
         if ($this->client) {

composer.json

@@ -6,17 +6,21 @@
     "homepage": "https://enqueue.forma-pro.com/",
     "license": "MIT",
     "require": {
-        "php": "^7.1.3",
-        "queue-interop/queue-interop": "^0.7",
-        "enqueue/dsn": "0.9.x-dev",
-        "thruway/pawl-transport": "^0.5.0",
-        "voryx/thruway": "^0.5.3"
+        "php": "^8.1",
+        "queue-interop/queue-interop": "^0.8.1",
+        "enqueue/dsn": "^0.10.8",
+        "thruway/client": "^0.5.5",
+        "thruway/pawl-transport": "^0.5.1",
+        "voryx/thruway-common": "^1.0.1",
+        "react/dns": "^1.4",
+        "react/event-loop": "^1.2",
+        "react/promise": "^2.8"
     },
     "require-dev": {
-        "phpunit/phpunit": "~5.4.0",
-        "enqueue/test": "0.9.x-dev",
-        "enqueue/null": "0.9.x-dev",
-        "queue-interop/queue-spec": "^0.6"
+        "phpunit/phpunit": "^9.5",
+        "enqueue/test": "0.10.x-dev",
+        "enqueue/null": "0.10.x-dev",
+        "queue-interop/queue-spec": "^0.6.2"
     },
     "support": {
         "email": "opensource@forma-pro.com",
@@ -31,10 +35,13 @@
             "/Tests/"
         ]
     },
-    "minimum-stability": "dev",
+    "minimum-stability": "beta",
     "extra": {
         "branch-alias": {
-            "dev-master": "0.9.x-dev"
+            "dev-master": "0.10.x-dev"
         }
+    },
+    "config": {
+        "prefer-stable": true
     }
 }

phpunit.xml.dist

@@ -1,16 +1,11 @@
 <?xml version="1.0" encoding="UTF-8"?>
 
-<phpunit backupGlobals="false"
-         backupStaticAttributes="false"
-         colors="true"
-         convertErrorsToExceptions="true"
-         convertNoticesToExceptions="true"
-         convertWarningsToExceptions="true"
-         processIsolation="false"
-         stopOnFailure="false"
-         syntaxCheck="false"
-         bootstrap="./vendor/autoload.php"
-        >
+<phpunit
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/7.5/phpunit.xsd"
+    colors="true"
+    bootstrap="./vendor/autoload.php"
+>
 
     <testsuites>
         <testsuite name="Message Queue WAMP Transport Test Suite">